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);
