wip

test/transformers/backpressure/buffer_count_test.dart

@@ -118,7 +118,7 @@ void main() {
   });
 
   test('Rx.bufferCount.nullable', () {
-    testNullable<List<String?>>(
+    nullableTest<List<String?>>(
       (s) => s.bufferCount(1),
     );
   });

test/transformers/backpressure/buffer_test.dart

@@ -111,7 +111,7 @@ void main() {
   });
 
   test('Rx.buffer.nullable', () {
-    testNullable<List<String?>>(
+    nullableTest<List<String?>>(
       (s) => s.buffer(Stream<void>.empty()),
     );
   });

test/transformers/backpressure/buffer_test_test.dart

@@ -60,7 +60,7 @@ void main() {
   });
 
   test('Rx.bufferTest.nullable', () {
-    testNullable<List<String?>>(
+    nullableTest<List<String?>>(
       (s) => s.bufferTest((i) => true),
     );
   });

test/transformers/backpressure/buffer_time_test.dart

@@ -89,7 +89,7 @@ void main() {
   });
 
   test('Rx.bufferTime.nullable', () {
-    testNullable<List<String?>>(
+    nullableTest<List<String?>>(
       (s) => s.bufferTime(Duration.zero),
     );
   });

test/transformers/backpressure/debounce_test.dart

@@ -138,7 +138,7 @@ void main() {
   });
 
   test('Rx.debounce.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.debounce((_) => Stream<void>.empty()),
     );
   });

test/transformers/backpressure/debounce_time_test.dart

@@ -119,7 +119,7 @@ void main() {
   });
 
   test('Rx.debounceTime.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.debounceTime(Duration.zero),
     );
   });

test/transformers/backpressure/pairwise_test.dart

@@ -48,7 +48,7 @@ void main() {
   });
 
   test('Rx.pairwise.nullable', () {
-    testNullable<Iterable<String?>>(
+    nullableTest<Iterable<String?>>(
       (s) => s.pairwise(),
     );
   });

test/transformers/backpressure/sample_test.dart

@@ -102,7 +102,7 @@ void main() {
   });
 
   test('Rx.sample.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.sample(_getSampleStream()),
     );
   });

test/transformers/backpressure/sample_time_test.dart

@@ -92,7 +92,7 @@ void main() {
   });
 
   test('Rx.sampleTime.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.sampleTime(Duration.zero),
     );
   });

test/transformers/backpressure/throttle_test.dart

@@ -153,7 +153,7 @@ void main() {
   });
 
   test('Rx.throttle.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.throttle((_) => Stream<void>.empty()),
     );
   });

test/transformers/backpressure/throttle_time_test.dart

@@ -95,7 +95,7 @@ void main() {
   });
 
   test('Rx.throttleTime.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.throttleTime(Duration.zero),
     );
   });

test/transformers/backpressure/window_count_test.dart

@@ -118,7 +118,7 @@ void main() {
   });
 
   test('Rx.windowCount.nullable', () {
-    testNullable<Stream<String?>>(
+    nullableTest<Stream<String?>>(
       (s) => s.windowCount(2),
     );
   });

test/transformers/backpressure/window_test.dart

@@ -116,7 +116,7 @@ void main() {
   });
 
   test('Rx.window.nullable', () {
-    testNullable<Stream<String?>>(
+    nullableTest<Stream<String?>>(
       (s) => s.window(Stream<void>.empty()),
     );
   });

test/transformers/backpressure/window_test_test.dart

@@ -60,7 +60,7 @@ void main() {
   });
 
   test('Rx.windowTest.nullable', () {
-    testNullable<Stream<String?>>(
+    nullableTest<Stream<String?>>(
       (s) => s.windowTest((_) => true),
     );
   });

test/transformers/backpressure/window_time_test.dart

@@ -92,7 +92,7 @@ void main() {
   });
 
   test('Rx.windowTime.nullable', () {
-    testNullable<Stream<String?>>(
+    nullableTest<Stream<String?>>(
       (s) => s.windowTime(Duration.zero),
     );
   });

test/transformers/default_if_empty_test.dart

@@ -81,7 +81,7 @@ void main() {
   });
 
   test('Rx.defaultIfEmpty.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.defaultIfEmpty(null),
     );
   });

test/transformers/delay_test.dart

@@ -120,7 +120,7 @@ void main() {
   });
 
   test('Rx.delay.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.delay(Duration.zero),
     );
   });

test/transformers/delay_when_test.dart

@@ -273,7 +273,7 @@ void main() {
   });
 
   test('Rx.delayWhen.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.delayWhen((_) => Duration.zero.asTimerStream()),
     );
   });

test/transformers/distinct_unique_test.dart

@@ -131,7 +131,7 @@ void main() {
   });
 
   test('Rx.distinctUnique.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.distinctUnique(),
     );
   });

test/transformers/do_test.dart

@@ -481,7 +481,7 @@ void main() {
     });
 
     test('doOnData nullable', () {
-      testNullable<String?>(
+      nullableTest<String?>(
         (s) => s.doOnData((d) {}),
       );
     });

test/transformers/end_with_many_test.dart

@@ -71,7 +71,7 @@ void main() {
   });
 
   test('Rx.endWithMany.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.endWithMany(['String']),
     );
   });

test/transformers/end_with_test.dart

@@ -69,7 +69,7 @@ void main() {
   });
 
   test('Rx.endWith.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.endWith('String'),
     );
   });

test/transformers/exhaust_map_test.dart

@@ -102,7 +102,7 @@ void main() {
     });
 
     test('Rx.exhaustMap.nullable', () {
-      testNullable<String?>(
+      nullableTest<String?>(
         (s) => s.exhaustMap((v) => Stream.value(v)),
       );
     });

test/transformers/flat_map_iterable_test.dart

@@ -27,7 +27,7 @@ void main() {
     });
 
     test('nullable', () {
-      testNullable<String?>(
+      nullableTest<String?>(
         (s) => s.flatMapIterable((v) => Stream.value([v])),
       );
     });

test/transformers/flat_map_test.dart

@@ -239,7 +239,7 @@ void main() {
   }, timeout: const Timeout(Duration(milliseconds: 200)));
 
   test('Rx.flatMap.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.flatMap((v) => Stream.value(v)),
     );
   });

test/transformers/group_by_test.dart

@@ -305,7 +305,7 @@ void main() {
   });
 
   test('Rx.groupBy.nullable', () {
-    testNullable<GroupedStream<String?, String?>>(
+    nullableTest<GroupedStream<String?, String?>>(
       (s) => s.groupBy((v) => v),
     );
   });

test/transformers/ignore_elements_test.dart

@@ -119,7 +119,7 @@ void main() {
   });
 
   test('Rx.ignoreElements.nullable', () {
-    testNullable<Never>(
+    nullableTest<Never>(
       (s) => s.ignoreElements(),
     );
   });

test/transformers/interval_test.dart

@@ -80,7 +80,7 @@ void main() {
   });
 
   test('Rx.interval.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.interval(Duration.zero),
     );
   });

test/transformers/map_not_null_test.dart

@@ -93,7 +93,7 @@ void main() {
   });
 
   test('Rx.mapNotNull.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.mapNotNull((i) => i),
     );
   });

test/transformers/map_to_test.dart

@@ -60,7 +60,7 @@ void main() {
   });
 
   test('Rx.mapTo.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.mapTo('String'),
     );
   });

test/transformers/materialize_test.dart

@@ -92,7 +92,7 @@ void main() {
   });
 
   test('Rx.materialize.nullable', () {
-    testNullable<Notification<String?>>(
+    nullableTest<Notification<String?>>(
       (s) => s.materialize(),
     );
   });

test/transformers/on_error_resume_test.dart

@@ -202,7 +202,7 @@ void main() {
   });
 
   test('Rx.onErrorResumeNext.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.onErrorResumeNext(Stream.empty()),
     );
   });

test/transformers/on_error_return_test.dart

@@ -73,7 +73,7 @@ void main() {
   });
 
   test('Rx.onErrorReturn.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.onErrorReturn('String'),
     );
   });

test/transformers/on_error_return_with_test.dart

@@ -75,7 +75,7 @@ void main() {
   });
 
   test('Rx.onErrorReturnWith.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.onErrorReturnWith((e, s) => 'String'),
     );
   });

test/transformers/scan_test.dart

@@ -18,7 +18,7 @@ void main() {
   });
 
   test('Rx.scan.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.scan((acc, value, index) => acc, null),
     );
 

test/transformers/skip_last_test.dart

@@ -103,7 +103,7 @@ void main() {
   });
 
   test('Rx.skipLast.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.skipLast(1),
     );
   });

test/transformers/skip_until_test.dart

@@ -123,7 +123,7 @@ void main() {
   });
 
   test('Rx.skipUntil.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.skipUntil(Stream<void>.empty()),
     );
   });

test/transformers/start_with_many_test.dart

@@ -80,7 +80,7 @@ void main() {
   });
 
   test('Rx.startWithMany.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.startWithMany([]),
     );
   });

test/transformers/start_with_test.dart

@@ -95,7 +95,7 @@ void main() {
   }, skip: true);
 
   test('Rx.startWith.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.startWith('String'),
     );
   });

test/transformers/switch_if_empty_test.dart

@@ -89,7 +89,7 @@ void main() {
   });
 
   test('Rx.switchIfEmpty.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.switchIfEmpty(Stream.value('String')),
     );
   });

test/transformers/switch_map_test.dart

@@ -171,7 +171,7 @@ void main() {
   });
 
   test('Rx.switchMap.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.switchMap((v) => Stream.value(v)),
     );
   });

test/transformers/take_last_test.dart

@@ -102,7 +102,7 @@ void main() {
   }, timeout: const Timeout(Duration(seconds: 1)));
 
   test('Rx.takeLast.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.takeLast(1),
     );
   });

test/transformers/take_until_test.dart

@@ -113,7 +113,7 @@ void main() {
   });
 
   test('Rx.takeUntil.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.takeUntil(Stream<void>.empty()),
     );
   });

test/transformers/take_while_inclusive_test.dart

@@ -85,7 +85,7 @@ void main() {
   });
 
   test('Rx.takeWhileInclusive.nullable', () {
-    testNullable<String?>(
+    nullableTest<String?>(
       (s) => s.takeWhileInclusive((_) => true),
     );
   });