Google Git
Sign in
dart/tools.git/fbeb8df5^!/.
commit
fbeb8df59ff12d3232d7910d75a2dec23f69e44e
[log]
author
Kevin Moore <kevmoo@users.noreply.github.com>
Mon Jul 12 15:03:36 2021 -0700
committer
GitHub <noreply@github.com>
Mon Jul 12 15:03:36 2021 -0700
tree
dd1cb49e97012e42843835c39939c90c27e1feca
parent
ef2074e675e1c8c89f1a4eeef5bf3988585d2202 [diff]
Dart format with latest SDK (dart-lang/stream_transform#134)


diff --git a/pkgs/stream_transform/test/async_map_buffer_test.dart b/pkgs/stream_transform/test/async_map_buffer_test.dart
index f527a0e..b43c617 100644
--- a/pkgs/stream_transform/test/async_map_buffer_test.dart
+++ b/pkgs/stream_transform/test/async_map_buffer_test.dart

@@ -71,7 +71,9 @@
       test('buffers values while work is ongoing', () async {
         values.add(1);
         await Future(() {});
-        values..add(2)..add(3);
+        values
+          ..add(2)
+          ..add(3);
         await Future(() {});
         finishWork!.complete('');
         await Future(() {});

diff --git a/pkgs/stream_transform/test/async_map_sample_test.dart b/pkgs/stream_transform/test/async_map_sample_test.dart
index c32b7a7..6cab7d0 100644
--- a/pkgs/stream_transform/test/async_map_sample_test.dart
+++ b/pkgs/stream_transform/test/async_map_sample_test.dart

@@ -71,7 +71,9 @@
       test('buffers values while work is ongoing', () async {
         values.add(1);
         await Future(() {});
-        values..add(2)..add(3);
+        values
+          ..add(2)
+          ..add(3);
         await Future(() {});
         finishWork!.complete('');
         await Future(() {});

diff --git a/pkgs/stream_transform/test/async_where_test.dart b/pkgs/stream_transform/test/async_where_test.dart
index 43f0239..3a13a38 100644
--- a/pkgs/stream_transform/test/async_where_test.dart
+++ b/pkgs/stream_transform/test/async_where_test.dart

@@ -39,8 +39,14 @@
     var filtered = values.stream.asyncWhere((e) async => e > 2);
     var firstValues = [];
     var secondValues = [];
-    filtered..listen(firstValues.add)..listen(secondValues.add);
-    values..add(1)..add(2)..add(3)..add(4);
+    filtered
+      ..listen(firstValues.add)
+      ..listen(secondValues.add);
+    values
+      ..add(1)
+      ..add(2)
+      ..add(3)
+      ..add(4);
     await Future(() {});
     expect(firstValues, [3, 4]);
     expect(secondValues, [3, 4]);

diff --git a/pkgs/stream_transform/test/audit_test.dart b/pkgs/stream_transform/test/audit_test.dart
index e06c962..cc8f08a 100644
--- a/pkgs/stream_transform/test/audit_test.dart
+++ b/pkgs/stream_transform/test/audit_test.dart

@@ -43,7 +43,9 @@
         });
 
         test('swallows values that come faster than duration', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [2]);
@@ -90,7 +92,9 @@
           test('multiple listeners all get values', () async {
             var otherValues = [];
             transformed.listen(otherValues.add);
-            values..add(1)..add(2);
+            values
+              ..add(1)
+              ..add(2);
             await waitForTimer(5);
             expect(emittedValues, [2]);
             expect(otherValues, [2]);

diff --git a/pkgs/stream_transform/test/buffer_test.dart b/pkgs/stream_transform/test/buffer_test.dart
index 68f3847..fc17f4b 100644
--- a/pkgs/stream_transform/test/buffer_test.dart
+++ b/pkgs/stream_transform/test/buffer_test.dart

@@ -77,9 +77,13 @@
         });
 
         test('two triggers in a row - emit then emit next value', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await Future(() {});
-          trigger..add(null)..add(null);
+          trigger
+            ..add(null)
+            ..add(null);
           await Future(() {});
           values.add(3);
           await Future(() {});
@@ -92,7 +96,9 @@
         test('pre-emptive trigger then trigger after values', () async {
           trigger.add(null);
           await Future(() {});
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await Future(() {});
           trigger.add(null);
           await Future(() {});
@@ -103,9 +109,13 @@
         });
 
         test('multiple pre-emptive triggers, only emits first value', () async {
-          trigger..add(null)..add(null);
+          trigger
+            ..add(null)
+            ..add(null);
           await Future(() {});
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await Future(() {});
           expect(emittedValues, [
             [1]
@@ -113,10 +123,14 @@
         });
 
         test('groups values between trigger', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await Future(() {});
           trigger.add(null);
-          values..add(3)..add(4);
+          values
+            ..add(3)
+            ..add(4);
           await Future(() {});
           trigger.add(null);
           await Future(() {});

diff --git a/pkgs/stream_transform/test/combine_latest_test.dart b/pkgs/stream_transform/test/combine_latest_test.dart
index 8c4b66f..a463bce 100644
--- a/pkgs/stream_transform/test/combine_latest_test.dart
+++ b/pkgs/stream_transform/test/combine_latest_test.dart

@@ -50,7 +50,9 @@
           .combineLatest(other.stream, times)
           .forEach(results.add));
 
-      source..add('a')..add('b');
+      source
+        ..add('a')
+        ..add('b');
       await Future(() {});
       expect(results, isEmpty);
 

diff --git a/pkgs/stream_transform/test/concurrent_async_expand_test.dart b/pkgs/stream_transform/test/concurrent_async_expand_test.dart
index d0b4ad4..3794165 100644
--- a/pkgs/stream_transform/test/concurrent_async_expand_test.dart
+++ b/pkgs/stream_transform/test/concurrent_async_expand_test.dart

@@ -61,7 +61,9 @@
         });
 
         test('interleaves events from sub streams', () async {
-          outerController..add(1)..add(2);
+          outerController
+            ..add(1)
+            ..add(2);
           await Future<void>(() {});
           expect(emittedValues, isEmpty);
           expect(innerControllers, hasLength(2));
@@ -79,7 +81,9 @@
         });
 
         test('forwards errors from inner streams', () async {
-          outerController..add(1)..add(2);
+          outerController
+            ..add(1)
+            ..add(2);
           await Future<void>(() {});
           innerControllers[0].addError('Error 1');
           innerControllers[1].addError('Error 2');
@@ -108,7 +112,9 @@
           // A single subscription inner stream in a broadcast outer stream is
           // not canceled.
           test('cancels inner subscriptions if output canceled', () async {
-            outerController..add(1)..add(2);
+            outerController
+              ..add(1)
+              ..add(2);
             await Future<void>(() {});
             await subscription.cancel();
             expect(innerCanceled, [true, true]);
@@ -164,7 +170,9 @@
           });
 
           test('can cancel and relisten', () async {
-            outerController..add(1)..add(2);
+            outerController
+              ..add(1)
+              ..add(2);
             await Future(() {});
             innerControllers[0].add('First');
             innerControllers[1].add('Second');

diff --git a/pkgs/stream_transform/test/concurrent_async_map_test.dart b/pkgs/stream_transform/test/concurrent_async_map_test.dart
index c47ff87..3c46a96 100644
--- a/pkgs/stream_transform/test/concurrent_async_map_test.dart
+++ b/pkgs/stream_transform/test/concurrent_async_map_test.dart

@@ -59,7 +59,10 @@
       });
 
       test('allows calls to convert before the last one finished', () async {
-        controller..add(1)..add(2)..add(3);
+        controller
+          ..add(1)
+          ..add(2)
+          ..add(3);
         await Future(() {});
         expect(values, [1, 2, 3]);
       });

diff --git a/pkgs/stream_transform/test/debounce_test.dart b/pkgs/stream_transform/test/debounce_test.dart
index 38ee436..f9c97eb 100644
--- a/pkgs/stream_transform/test/debounce_test.dart
+++ b/pkgs/stream_transform/test/debounce_test.dart

@@ -43,7 +43,9 @@
         });
 
         test('swallows values that come faster than duration', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [2]);
@@ -80,7 +82,9 @@
           test('multiple listeners all get values', () async {
             var otherValues = [];
             transformed.listen(otherValues.add);
-            values..add(1)..add(2);
+            values
+              ..add(1)
+              ..add(2);
             await waitForTimer(5);
             expect(emittedValues, [2]);
             expect(otherValues, [2]);
@@ -106,7 +110,9 @@
         });
 
         test('swallows values that come faster than duration', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           expect(emittedValues, [1]);
         });
@@ -123,7 +129,9 @@
           test('multiple listeners all get values', () async {
             var otherValues = [];
             transformed.listen(otherValues.add);
-            values..add(1)..add(2);
+            values
+              ..add(1)
+              ..add(2);
             await waitForTimer(5);
             expect(emittedValues, [1]);
             expect(otherValues, [1]);
@@ -152,7 +160,10 @@
         });
 
         test('swallows values that come faster than duration', () async {
-          values..add(1)..add(2)..add(3);
+          values
+            ..add(1)
+            ..add(2)
+            ..add(3);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [1, 3]);
@@ -170,7 +181,9 @@
           test('multiple listeners all get values', () async {
             var otherValues = [];
             transformed.listen(otherValues.add);
-            values..add(1)..add(2);
+            values
+              ..add(1)
+              ..add(2);
             await waitForTimer(5);
             expect(emittedValues, [1, 2]);
             expect(otherValues, [1, 2]);
@@ -190,11 +203,13 @@
           errors = [];
           transformed = values.stream
               .debounceBuffer(const Duration(milliseconds: 5))
-                ..listen(emittedValues.add, onError: errors.add);
+            ..listen(emittedValues.add, onError: errors.add);
         });
 
         test('Emits all values as a list', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [
@@ -218,7 +233,9 @@
           test('multiple listeners all get values', () async {
             var otherValues = [];
             transformed.listen(otherValues.add);
-            values..add(1)..add(2);
+            values
+              ..add(1)
+              ..add(2);
             await waitForTimer(5);
             expect(emittedValues, [
               [1, 2]

diff --git a/pkgs/stream_transform/test/followd_by_test.dart b/pkgs/stream_transform/test/followd_by_test.dart
index 69b0a99..436d613 100644
--- a/pkgs/stream_transform/test/followd_by_test.dart
+++ b/pkgs/stream_transform/test/followd_by_test.dart

@@ -50,10 +50,14 @@
         });
 
         test('adds all values from both streams', () async {
-          first..add(1)..add(2);
+          first
+            ..add(1)
+            ..add(2);
           await first.close();
           await Future(() {});
-          second..add(3)..add(4);
+          second
+            ..add(3)
+            ..add(4);
           await Future(() {});
           expect(emittedValues, [1, 2, 3, 4]);
         });

diff --git a/pkgs/stream_transform/test/from_handlers_test.dart b/pkgs/stream_transform/test/from_handlers_test.dart
index f2f3546..4e9134f 100644
--- a/pkgs/stream_transform/test/from_handlers_test.dart
+++ b/pkgs/stream_transform/test/from_handlers_test.dart

@@ -44,7 +44,9 @@
       });
 
       test('forwards values', () async {
-        values..add(1)..add(2);
+        values
+          ..add(1)
+          ..add(2);
         await Future(() {});
         expect(emittedValues, [1, 2]);
       });
@@ -89,7 +91,9 @@
       });
 
       test('forwards values', () async {
-        values..add(1)..add(2);
+        values
+          ..add(1)
+          ..add(2);
         await Future(() {});
         expect(emittedValues, [1, 2]);
         expect(emittedValues2, [1, 2]);
@@ -127,7 +131,9 @@
                 }));
       });
       test('uses transform from handleData', () async {
-        values..add(1)..add(2);
+        values
+          ..add(1)
+          ..add(2);
         await Future(() {});
         expect(emittedValues, [2, 3]);
       });

diff --git a/pkgs/stream_transform/test/scan_test.dart b/pkgs/stream_transform/test/scan_test.dart
index aaa099c..49bb8b8 100644
--- a/pkgs/stream_transform/test/scan_test.dart
+++ b/pkgs/stream_transform/test/scan_test.dart

@@ -78,7 +78,9 @@
 
         unawaited(source.stream.scan(0, combine).forEach(results.add));
 
-        source..add(1)..add(2);
+        source
+          ..add(1)
+          ..add(2);
         await Future(() {});
         expect(calledWith, [1]);
         expect(results, isEmpty);

diff --git a/pkgs/stream_transform/test/start_with_test.dart b/pkgs/stream_transform/test/start_with_test.dart
index 71758b5..35f0330 100644
--- a/pkgs/stream_transform/test/start_with_test.dart
+++ b/pkgs/stream_transform/test/start_with_test.dart

@@ -32,7 +32,9 @@
       setUp(() => setupForStreamType(streamType, (s) => s.startWith(1)));
 
       test('outputs all values', () async {
-        values..add(2)..add(3);
+        values
+          ..add(2)
+          ..add(3);
         await Future(() {});
         expect(emittedValues, [1, 2, 3]);
       });
@@ -70,7 +72,9 @@
       });
 
       test('outputs all values', () async {
-        values..add(3)..add(4);
+        values
+          ..add(3)
+          ..add(4);
         await Future(() {});
         expect(emittedValues, [1, 2, 3, 4]);
       });
@@ -109,9 +113,13 @@
         });
 
         test('outputs all values', () async {
-          starting..add(1)..add(2);
+          starting
+            ..add(1)
+            ..add(2);
           await starting.close();
-          values..add(3)..add(4);
+          values
+            ..add(3)
+            ..add(4);
           await Future(() {});
           expect(emittedValues, [1, 2, 3, 4]);
         });
@@ -132,13 +140,17 @@
             subscription = transformed.listen(emittedValues.add);
             starting.add(2);
             await starting.close();
-            values..add(3)..add(4);
+            values
+              ..add(3)
+              ..add(4);
             await Future(() {});
             expect(emittedValues, [1, 2, 3, 4]);
           });
 
           test('can cancel and relisten during values', () async {
-            starting..add(1)..add(2);
+            starting
+              ..add(1)
+              ..add(2);
             await starting.close();
             values.add(3);
             await Future(() {});

diff --git a/pkgs/stream_transform/test/switch_test.dart b/pkgs/stream_transform/test/switch_test.dart
index 8cae7c4..e35cb0a 100644
--- a/pkgs/stream_transform/test/switch_test.dart
+++ b/pkgs/stream_transform/test/switch_test.dart

@@ -49,12 +49,16 @@
         test('forwards events', () async {
           outer.add(first.stream);
           await Future(() {});
-          first..add(1)..add(2);
+          first
+            ..add(1)
+            ..add(2);
           await Future(() {});
 
           outer.add(second.stream);
           await Future(() {});
-          second..add(3)..add(4);
+          second
+            ..add(3)
+            ..add(4);
           await Future(() {});
 
           expect(emittedValues, [1, 2, 3, 4]);

diff --git a/pkgs/stream_transform/test/take_until_test.dart b/pkgs/stream_transform/test/take_until_test.dart
index 7cd30f8..fe6ed1d 100644
--- a/pkgs/stream_transform/test/take_until_test.dart
+++ b/pkgs/stream_transform/test/take_until_test.dart

@@ -44,7 +44,9 @@
       });
 
       test('lets values through before trigger', () async {
-        values..add(1)..add(2);
+        values
+          ..add(1)
+          ..add(2);
         await Future(() {});
         expect(emittedValues, [1, 2]);
       });
@@ -76,7 +78,9 @@
         test('multiple listeners all get values', () async {
           var otherValues = [];
           transformed.listen(otherValues.add);
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await Future(() {});
           expect(emittedValues, [1, 2]);
           expect(otherValues, [1, 2]);

diff --git a/pkgs/stream_transform/test/throttle_test.dart b/pkgs/stream_transform/test/throttle_test.dart
index 52c79b5..22bf5b3 100644
--- a/pkgs/stream_transform/test/throttle_test.dart
+++ b/pkgs/stream_transform/test/throttle_test.dart

@@ -40,7 +40,9 @@
         });
 
         test('swallows values that come faster than duration', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [1]);
@@ -91,14 +93,19 @@
         });
 
         test('emits both first and last in a period', () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [1, 2]);
         });
 
         test('swallows values that are not the latest in a period', () async {
-          values..add(1)..add(2)..add(3);
+          values
+            ..add(1)
+            ..add(2)
+            ..add(3);
           await values.close();
           await waitForTimer(5);
           expect(emittedValues, [1, 3]);
@@ -106,7 +113,9 @@
 
         test('waits to output the last value even if the stream closes',
             () async {
-          values..add(1)..add(2);
+          values
+            ..add(1)
+            ..add(2);
           await values.close();
           await Future(() {});
           expect(isDone, false);
@@ -128,7 +137,9 @@
           test('multiple listeners all get values', () async {
             var otherValues = <int>[];
             transformed.listen(otherValues.add);
-            values..add(1)..add(2);
+            values
+              ..add(1)
+              ..add(2);
             await Future(() {});
             expect(emittedValues, [1]);
             expect(otherValues, [1]);

diff --git a/pkgs/stream_transform/test/where_type_test.dart b/pkgs/stream_transform/test/where_type_test.dart
index 03e259a..1a65dd6 100644
--- a/pkgs/stream_transform/test/where_type_test.dart
+++ b/pkgs/stream_transform/test/where_type_test.dart

@@ -25,8 +25,14 @@
     var filtered = values.stream.whereType<String>();
     var firstValues = [];
     var secondValues = [];
-    filtered..listen(firstValues.add)..listen(secondValues.add);
-    values..add(1)..add('a')..add(2)..add('b');
+    filtered
+      ..listen(firstValues.add)
+      ..listen(secondValues.add);
+    values
+      ..add(1)
+      ..add('a')
+      ..add(2)
+      ..add('b');
     await Future(() {});
     expect(firstValues, ['a', 'b']);
     expect(secondValues, ['a', 'b']);
@@ -40,7 +46,9 @@
     filtered
       ..listen(null, onDone: () => firstDone = true)
       ..listen(null, onDone: () => secondDone = true);
-    values..add(1)..add('a');
+    values
+      ..add(1)
+      ..add('a');
     await values.close();
     expect(firstDone, true);
     expect(secondDone, true);