diff --git a/test/transformers/backpressure/buffer_count_test.dart b/test/transformers/backpressure/buffer_count_test.dart index f669791a8..169436abd 100644 --- a/test/transformers/backpressure/buffer_count_test.dart +++ b/test/transformers/backpressure/buffer_count_test.dart @@ -118,7 +118,7 @@ void main() { }); test('Rx.bufferCount.nullable', () { - testNullable>( + nullableTest>( (s) => s.bufferCount(1), ); }); diff --git a/test/transformers/backpressure/buffer_test.dart b/test/transformers/backpressure/buffer_test.dart index 5d9ce0562..959b1bccb 100644 --- a/test/transformers/backpressure/buffer_test.dart +++ b/test/transformers/backpressure/buffer_test.dart @@ -111,7 +111,7 @@ void main() { }); test('Rx.buffer.nullable', () { - testNullable>( + nullableTest>( (s) => s.buffer(Stream.empty()), ); }); diff --git a/test/transformers/backpressure/buffer_test_test.dart b/test/transformers/backpressure/buffer_test_test.dart index cd1dd6ad8..2f3c91876 100644 --- a/test/transformers/backpressure/buffer_test_test.dart +++ b/test/transformers/backpressure/buffer_test_test.dart @@ -60,7 +60,7 @@ void main() { }); test('Rx.bufferTest.nullable', () { - testNullable>( + nullableTest>( (s) => s.bufferTest((i) => true), ); }); diff --git a/test/transformers/backpressure/buffer_time_test.dart b/test/transformers/backpressure/buffer_time_test.dart index 5e6fd4629..8f2f509f6 100644 --- a/test/transformers/backpressure/buffer_time_test.dart +++ b/test/transformers/backpressure/buffer_time_test.dart @@ -89,7 +89,7 @@ void main() { }); test('Rx.bufferTime.nullable', () { - testNullable>( + nullableTest>( (s) => s.bufferTime(Duration.zero), ); }); diff --git a/test/transformers/backpressure/debounce_test.dart b/test/transformers/backpressure/debounce_test.dart index 00f526ae6..bf7458052 100644 --- a/test/transformers/backpressure/debounce_test.dart +++ b/test/transformers/backpressure/debounce_test.dart @@ -138,7 +138,7 @@ void main() { }); test('Rx.debounce.nullable', () { - testNullable( + nullableTest( (s) => s.debounce((_) => Stream.empty()), ); }); diff --git a/test/transformers/backpressure/debounce_time_test.dart b/test/transformers/backpressure/debounce_time_test.dart index 3033a1f46..ee3e75fdb 100644 --- a/test/transformers/backpressure/debounce_time_test.dart +++ b/test/transformers/backpressure/debounce_time_test.dart @@ -119,7 +119,7 @@ void main() { }); test('Rx.debounceTime.nullable', () { - testNullable( + nullableTest( (s) => s.debounceTime(Duration.zero), ); }); diff --git a/test/transformers/backpressure/pairwise_test.dart b/test/transformers/backpressure/pairwise_test.dart index 68f68de8e..4d9a35b44 100644 --- a/test/transformers/backpressure/pairwise_test.dart +++ b/test/transformers/backpressure/pairwise_test.dart @@ -48,7 +48,7 @@ void main() { }); test('Rx.pairwise.nullable', () { - testNullable>( + nullableTest>( (s) => s.pairwise(), ); }); diff --git a/test/transformers/backpressure/sample_test.dart b/test/transformers/backpressure/sample_test.dart index 3c7354530..5181428bc 100644 --- a/test/transformers/backpressure/sample_test.dart +++ b/test/transformers/backpressure/sample_test.dart @@ -102,7 +102,7 @@ void main() { }); test('Rx.sample.nullable', () { - testNullable( + nullableTest( (s) => s.sample(_getSampleStream()), ); }); diff --git a/test/transformers/backpressure/sample_time_test.dart b/test/transformers/backpressure/sample_time_test.dart index 5f710fa0c..797cacbd7 100644 --- a/test/transformers/backpressure/sample_time_test.dart +++ b/test/transformers/backpressure/sample_time_test.dart @@ -92,7 +92,7 @@ void main() { }); test('Rx.sampleTime.nullable', () { - testNullable( + nullableTest( (s) => s.sampleTime(Duration.zero), ); }); diff --git a/test/transformers/backpressure/throttle_test.dart b/test/transformers/backpressure/throttle_test.dart index f32998fe7..e73edb1fd 100644 --- a/test/transformers/backpressure/throttle_test.dart +++ b/test/transformers/backpressure/throttle_test.dart @@ -153,7 +153,7 @@ void main() { }); test('Rx.throttle.nullable', () { - testNullable( + nullableTest( (s) => s.throttle((_) => Stream.empty()), ); }); diff --git a/test/transformers/backpressure/throttle_time_test.dart b/test/transformers/backpressure/throttle_time_test.dart index aec498405..b84dc119c 100644 --- a/test/transformers/backpressure/throttle_time_test.dart +++ b/test/transformers/backpressure/throttle_time_test.dart @@ -95,7 +95,7 @@ void main() { }); test('Rx.throttleTime.nullable', () { - testNullable( + nullableTest( (s) => s.throttleTime(Duration.zero), ); }); diff --git a/test/transformers/backpressure/window_count_test.dart b/test/transformers/backpressure/window_count_test.dart index 3d3e4f626..6709c7b68 100644 --- a/test/transformers/backpressure/window_count_test.dart +++ b/test/transformers/backpressure/window_count_test.dart @@ -118,7 +118,7 @@ void main() { }); test('Rx.windowCount.nullable', () { - testNullable>( + nullableTest>( (s) => s.windowCount(2), ); }); diff --git a/test/transformers/backpressure/window_test.dart b/test/transformers/backpressure/window_test.dart index 452c71227..f93fce949 100644 --- a/test/transformers/backpressure/window_test.dart +++ b/test/transformers/backpressure/window_test.dart @@ -116,7 +116,7 @@ void main() { }); test('Rx.window.nullable', () { - testNullable>( + nullableTest>( (s) => s.window(Stream.empty()), ); }); diff --git a/test/transformers/backpressure/window_test_test.dart b/test/transformers/backpressure/window_test_test.dart index fda37346a..12535fa71 100644 --- a/test/transformers/backpressure/window_test_test.dart +++ b/test/transformers/backpressure/window_test_test.dart @@ -60,7 +60,7 @@ void main() { }); test('Rx.windowTest.nullable', () { - testNullable>( + nullableTest>( (s) => s.windowTest((_) => true), ); }); diff --git a/test/transformers/backpressure/window_time_test.dart b/test/transformers/backpressure/window_time_test.dart index 8c5aab640..75aaeb337 100644 --- a/test/transformers/backpressure/window_time_test.dart +++ b/test/transformers/backpressure/window_time_test.dart @@ -92,7 +92,7 @@ void main() { }); test('Rx.windowTime.nullable', () { - testNullable>( + nullableTest>( (s) => s.windowTime(Duration.zero), ); }); diff --git a/test/transformers/default_if_empty_test.dart b/test/transformers/default_if_empty_test.dart index d0478600d..1a0541f99 100644 --- a/test/transformers/default_if_empty_test.dart +++ b/test/transformers/default_if_empty_test.dart @@ -81,7 +81,7 @@ void main() { }); test('Rx.defaultIfEmpty.nullable', () { - testNullable( + nullableTest( (s) => s.defaultIfEmpty(null), ); }); diff --git a/test/transformers/delay_test.dart b/test/transformers/delay_test.dart index ed4807abd..006257625 100644 --- a/test/transformers/delay_test.dart +++ b/test/transformers/delay_test.dart @@ -120,7 +120,7 @@ void main() { }); test('Rx.delay.nullable', () { - testNullable( + nullableTest( (s) => s.delay(Duration.zero), ); }); diff --git a/test/transformers/delay_when_test.dart b/test/transformers/delay_when_test.dart index 9a255ef1f..f676798e9 100644 --- a/test/transformers/delay_when_test.dart +++ b/test/transformers/delay_when_test.dart @@ -273,7 +273,7 @@ void main() { }); test('Rx.delayWhen.nullable', () { - testNullable( + nullableTest( (s) => s.delayWhen((_) => Duration.zero.asTimerStream()), ); }); diff --git a/test/transformers/distinct_unique_test.dart b/test/transformers/distinct_unique_test.dart index b0d3970fb..16bb24808 100644 --- a/test/transformers/distinct_unique_test.dart +++ b/test/transformers/distinct_unique_test.dart @@ -131,7 +131,7 @@ void main() { }); test('Rx.distinctUnique.nullable', () { - testNullable( + nullableTest( (s) => s.distinctUnique(), ); }); diff --git a/test/transformers/do_test.dart b/test/transformers/do_test.dart index 570ff0a82..79253740b 100644 --- a/test/transformers/do_test.dart +++ b/test/transformers/do_test.dart @@ -481,7 +481,7 @@ void main() { }); test('doOnData nullable', () { - testNullable( + nullableTest( (s) => s.doOnData((d) {}), ); }); diff --git a/test/transformers/end_with_many_test.dart b/test/transformers/end_with_many_test.dart index 5557488b4..c2772258c 100644 --- a/test/transformers/end_with_many_test.dart +++ b/test/transformers/end_with_many_test.dart @@ -71,7 +71,7 @@ void main() { }); test('Rx.endWithMany.nullable', () { - testNullable( + nullableTest( (s) => s.endWithMany(['String']), ); }); diff --git a/test/transformers/end_with_test.dart b/test/transformers/end_with_test.dart index d3f71cf4f..7ffd379d9 100644 --- a/test/transformers/end_with_test.dart +++ b/test/transformers/end_with_test.dart @@ -69,7 +69,7 @@ void main() { }); test('Rx.endWith.nullable', () { - testNullable( + nullableTest( (s) => s.endWith('String'), ); }); diff --git a/test/transformers/exhaust_map_test.dart b/test/transformers/exhaust_map_test.dart index e38133c80..a0036f148 100644 --- a/test/transformers/exhaust_map_test.dart +++ b/test/transformers/exhaust_map_test.dart @@ -102,7 +102,7 @@ void main() { }); test('Rx.exhaustMap.nullable', () { - testNullable( + nullableTest( (s) => s.exhaustMap((v) => Stream.value(v)), ); }); diff --git a/test/transformers/flat_map_iterable_test.dart b/test/transformers/flat_map_iterable_test.dart index 16dd8c704..a6d472b74 100644 --- a/test/transformers/flat_map_iterable_test.dart +++ b/test/transformers/flat_map_iterable_test.dart @@ -27,7 +27,7 @@ void main() { }); test('nullable', () { - testNullable( + nullableTest( (s) => s.flatMapIterable((v) => Stream.value([v])), ); }); diff --git a/test/transformers/flat_map_test.dart b/test/transformers/flat_map_test.dart index 82c8677d5..30133e784 100644 --- a/test/transformers/flat_map_test.dart +++ b/test/transformers/flat_map_test.dart @@ -239,7 +239,7 @@ void main() { }, timeout: const Timeout(Duration(milliseconds: 200))); test('Rx.flatMap.nullable', () { - testNullable( + nullableTest( (s) => s.flatMap((v) => Stream.value(v)), ); }); diff --git a/test/transformers/group_by_test.dart b/test/transformers/group_by_test.dart index 09ff64d70..49f8d2413 100644 --- a/test/transformers/group_by_test.dart +++ b/test/transformers/group_by_test.dart @@ -305,7 +305,7 @@ void main() { }); test('Rx.groupBy.nullable', () { - testNullable>( + nullableTest>( (s) => s.groupBy((v) => v), ); }); diff --git a/test/transformers/ignore_elements_test.dart b/test/transformers/ignore_elements_test.dart index 2b16b0318..838846eea 100644 --- a/test/transformers/ignore_elements_test.dart +++ b/test/transformers/ignore_elements_test.dart @@ -119,7 +119,7 @@ void main() { }); test('Rx.ignoreElements.nullable', () { - testNullable( + nullableTest( (s) => s.ignoreElements(), ); }); diff --git a/test/transformers/interval_test.dart b/test/transformers/interval_test.dart index 52e2900e7..b6b9b235e 100644 --- a/test/transformers/interval_test.dart +++ b/test/transformers/interval_test.dart @@ -80,7 +80,7 @@ void main() { }); test('Rx.interval.nullable', () { - testNullable( + nullableTest( (s) => s.interval(Duration.zero), ); }); diff --git a/test/transformers/map_not_null_test.dart b/test/transformers/map_not_null_test.dart index fc17bec58..67e6847dc 100644 --- a/test/transformers/map_not_null_test.dart +++ b/test/transformers/map_not_null_test.dart @@ -93,7 +93,7 @@ void main() { }); test('Rx.mapNotNull.nullable', () { - testNullable( + nullableTest( (s) => s.mapNotNull((i) => i), ); }); diff --git a/test/transformers/map_to_test.dart b/test/transformers/map_to_test.dart index a5de6fc34..3e0a36472 100644 --- a/test/transformers/map_to_test.dart +++ b/test/transformers/map_to_test.dart @@ -60,7 +60,7 @@ void main() { }); test('Rx.mapTo.nullable', () { - testNullable( + nullableTest( (s) => s.mapTo('String'), ); }); diff --git a/test/transformers/materialize_test.dart b/test/transformers/materialize_test.dart index c62d6b674..d3b9d4d9d 100644 --- a/test/transformers/materialize_test.dart +++ b/test/transformers/materialize_test.dart @@ -92,7 +92,7 @@ void main() { }); test('Rx.materialize.nullable', () { - testNullable>( + nullableTest>( (s) => s.materialize(), ); }); diff --git a/test/transformers/on_error_resume_test.dart b/test/transformers/on_error_resume_test.dart index 1d4211aa0..ff6399a24 100644 --- a/test/transformers/on_error_resume_test.dart +++ b/test/transformers/on_error_resume_test.dart @@ -202,7 +202,7 @@ void main() { }); test('Rx.onErrorResumeNext.nullable', () { - testNullable( + nullableTest( (s) => s.onErrorResumeNext(Stream.empty()), ); }); diff --git a/test/transformers/on_error_return_test.dart b/test/transformers/on_error_return_test.dart index 42d23f846..80114e667 100644 --- a/test/transformers/on_error_return_test.dart +++ b/test/transformers/on_error_return_test.dart @@ -73,7 +73,7 @@ void main() { }); test('Rx.onErrorReturn.nullable', () { - testNullable( + nullableTest( (s) => s.onErrorReturn('String'), ); }); diff --git a/test/transformers/on_error_return_with_test.dart b/test/transformers/on_error_return_with_test.dart index 5ecd981ef..a33a22298 100644 --- a/test/transformers/on_error_return_with_test.dart +++ b/test/transformers/on_error_return_with_test.dart @@ -75,7 +75,7 @@ void main() { }); test('Rx.onErrorReturnWith.nullable', () { - testNullable( + nullableTest( (s) => s.onErrorReturnWith((e, s) => 'String'), ); }); diff --git a/test/transformers/scan_test.dart b/test/transformers/scan_test.dart index 4f211def1..086af6a73 100644 --- a/test/transformers/scan_test.dart +++ b/test/transformers/scan_test.dart @@ -18,7 +18,7 @@ void main() { }); test('Rx.scan.nullable', () { - testNullable( + nullableTest( (s) => s.scan((acc, value, index) => acc, null), ); diff --git a/test/transformers/skip_last_test.dart b/test/transformers/skip_last_test.dart index 5dec30d65..40f2a39b4 100644 --- a/test/transformers/skip_last_test.dart +++ b/test/transformers/skip_last_test.dart @@ -103,7 +103,7 @@ void main() { }); test('Rx.skipLast.nullable', () { - testNullable( + nullableTest( (s) => s.skipLast(1), ); }); diff --git a/test/transformers/skip_until_test.dart b/test/transformers/skip_until_test.dart index 4458d8ba5..926ad6d4b 100644 --- a/test/transformers/skip_until_test.dart +++ b/test/transformers/skip_until_test.dart @@ -123,7 +123,7 @@ void main() { }); test('Rx.skipUntil.nullable', () { - testNullable( + nullableTest( (s) => s.skipUntil(Stream.empty()), ); }); diff --git a/test/transformers/start_with_many_test.dart b/test/transformers/start_with_many_test.dart index 63fffeddd..536f48332 100644 --- a/test/transformers/start_with_many_test.dart +++ b/test/transformers/start_with_many_test.dart @@ -80,7 +80,7 @@ void main() { }); test('Rx.startWithMany.nullable', () { - testNullable( + nullableTest( (s) => s.startWithMany([]), ); }); diff --git a/test/transformers/start_with_test.dart b/test/transformers/start_with_test.dart index b4d93b9d4..e802b5d96 100644 --- a/test/transformers/start_with_test.dart +++ b/test/transformers/start_with_test.dart @@ -95,7 +95,7 @@ void main() { }, skip: true); test('Rx.startWith.nullable', () { - testNullable( + nullableTest( (s) => s.startWith('String'), ); }); diff --git a/test/transformers/switch_if_empty_test.dart b/test/transformers/switch_if_empty_test.dart index df1f2c2da..5ec0d2645 100644 --- a/test/transformers/switch_if_empty_test.dart +++ b/test/transformers/switch_if_empty_test.dart @@ -89,7 +89,7 @@ void main() { }); test('Rx.switchIfEmpty.nullable', () { - testNullable( + nullableTest( (s) => s.switchIfEmpty(Stream.value('String')), ); }); diff --git a/test/transformers/switch_map_test.dart b/test/transformers/switch_map_test.dart index 0f64ce1cb..ae6da3d05 100644 --- a/test/transformers/switch_map_test.dart +++ b/test/transformers/switch_map_test.dart @@ -171,7 +171,7 @@ void main() { }); test('Rx.switchMap.nullable', () { - testNullable( + nullableTest( (s) => s.switchMap((v) => Stream.value(v)), ); }); diff --git a/test/transformers/take_last_test.dart b/test/transformers/take_last_test.dart index 07ddcd258..49dfbb326 100644 --- a/test/transformers/take_last_test.dart +++ b/test/transformers/take_last_test.dart @@ -102,7 +102,7 @@ void main() { }, timeout: const Timeout(Duration(seconds: 1))); test('Rx.takeLast.nullable', () { - testNullable( + nullableTest( (s) => s.takeLast(1), ); }); diff --git a/test/transformers/take_until_test.dart b/test/transformers/take_until_test.dart index 567b061a7..fa5b9364d 100644 --- a/test/transformers/take_until_test.dart +++ b/test/transformers/take_until_test.dart @@ -113,7 +113,7 @@ void main() { }); test('Rx.takeUntil.nullable', () { - testNullable( + nullableTest( (s) => s.takeUntil(Stream.empty()), ); }); diff --git a/test/transformers/take_while_inclusive_test.dart b/test/transformers/take_while_inclusive_test.dart index 18587d7d2..c9ee379c9 100644 --- a/test/transformers/take_while_inclusive_test.dart +++ b/test/transformers/take_while_inclusive_test.dart @@ -85,7 +85,7 @@ void main() { }); test('Rx.takeWhileInclusive.nullable', () { - testNullable( + nullableTest( (s) => s.takeWhileInclusive((_) => true), ); }); diff --git a/test/transformers/time_interval_test.dart b/test/transformers/time_interval_test.dart index 3dc4e6072..ed9467838 100644 --- a/test/transformers/time_interval_test.dart +++ b/test/transformers/time_interval_test.dart @@ -105,7 +105,7 @@ void main() { }); test('Rx.timeInterval.nullable', () { - testNullable>( + nullableTest>( (s) => s.timeInterval(), ); }); diff --git a/test/transformers/timestamp_test.dart b/test/transformers/timestamp_test.dart index 619c4661b..f62b78412 100644 --- a/test/transformers/timestamp_test.dart +++ b/test/transformers/timestamp_test.dart @@ -98,7 +98,7 @@ void main() { }); test('Rx.timestamp.nullable', () { - testNullable>( + nullableTest>( (s) => s.timestamp(), ); }); diff --git a/test/transformers/where_not_null_test.dart b/test/transformers/where_not_null_test.dart index 220420d06..7e2605a9b 100644 --- a/test/transformers/where_not_null_test.dart +++ b/test/transformers/where_not_null_test.dart @@ -80,7 +80,7 @@ void main() { }); test('Rx.whereNotNull.nullable', () { - testNullable( + nullableTest( (s) => s.whereNotNull(), ); }); diff --git a/test/transformers/where_type_test.dart b/test/transformers/where_type_test.dart index 2ab5b1ea3..ba7d39109 100644 --- a/test/transformers/where_type_test.dart +++ b/test/transformers/where_type_test.dart @@ -87,7 +87,7 @@ void main() { }); test('Rx.whereType.nullable', () { - testNullable( + nullableTest( (s) => s.whereType(), ); }); diff --git a/test/transformers/with_latest_from_test.dart b/test/transformers/with_latest_from_test.dart index e65b7d171..c0bce6fbf 100644 --- a/test/transformers/with_latest_from_test.dart +++ b/test/transformers/with_latest_from_test.dart @@ -435,7 +435,7 @@ void main() { }); test('Rx.withLatestFrom.nullable', () { - testNullable>( + nullableTest>( (s) => s.withLatestFromList([Stream.value('String')]), ); }); diff --git a/test/utils.dart b/test/utils.dart index caaea1547..2a8f4fda9 100644 --- a/test/utils.dart +++ b/test/utils.dart @@ -21,5 +21,5 @@ import 'dart:async'; /// are *expected* to complete with a value. void unawaited(Future future) {} -void testNullable(Stream Function(Stream s) transform) => - transform(Stream.fromIterable(['1', '2', '3'])).listen(null); +void nullableTest(Stream Function(Stream s) transform) => + transform(Stream.fromIterable(['1', '2', '3']));