| Index: pkg/barback/test/stream_pool_test.dart
|
| diff --git a/pkg/barback/test/stream_pool_test.dart b/pkg/barback/test/stream_pool_test.dart
|
| index d7013292cb42551de8a5467f5c47c6bfab2dfba5..fafa1f502cb52ffa4680f5256145b28a70037a40 100644
|
| --- a/pkg/barback/test/stream_pool_test.dart
|
| +++ b/pkg/barback/test/stream_pool_test.dart
|
| @@ -50,9 +50,11 @@ main() {
|
| controller1.add("fifth");
|
|
|
| expect(newFuture(() {
|
| - return pool.stream.transform(new StreamTransformer(
|
| + return pool.stream.transform(new StreamTransformer.fromHandlers(
|
| handleData: (data, sink) => sink.add(["data", data]),
|
| - handleError: (error, sink) => sink.add(["error", error]))).toList();
|
| + handleError: (error, stackTrace, sink) {
|
| + sink.add(["error", error]);
|
| + })).toList();
|
| }), completion(equals([
|
| ["data", "first"],
|
| ["data", "second"],
|
| @@ -111,9 +113,10 @@ main() {
|
| controller2.addError("second");
|
|
|
| expect(newFuture(() {
|
| - return pool.stream.transform(new StreamTransformer(
|
| + return pool.stream.transform(new StreamTransformer.fromHandlers(
|
| handleData: (data, sink) => sink.add(data),
|
| - handleError: (error, sink) => sink.add(error))).toList();
|
| + handleError: (error, stackTrace, sink) { sink.add(error); }))
|
| + .toList();
|
| }), completion(isEmpty));
|
|
|
| pumpEventQueue().then((_) => pool.close());
|
|
|