Index: tests/lib/async/stream_transformer_test.dart |
diff --git a/tests/lib/async/stream_transformer_test.dart b/tests/lib/async/stream_transformer_test.dart |
index 3088076c57b4374d104ebe3a8739b44dc3400d80..7ebffbe857588454a2ebf7367655da2d5c8360a7 100644 |
--- a/tests/lib/async/stream_transformer_test.dart |
+++ b/tests/lib/async/stream_transformer_test.dart |
@@ -23,13 +23,15 @@ class MyStreamSubscription<T> implements StreamSubscription<T> { |
Future cancel() => null; |
void onData(void handleData(T data)) { |
- this.handleData = handleData == null ? _defaultData: handleData; |
+ this.handleData = handleData == null ? _defaultData : handleData; |
} |
+ |
void onError(Function handleError) { |
- this.handleError = handleError == null ? _defaultError: handleError; |
+ this.handleError = handleError == null ? _defaultError : handleError; |
} |
+ |
void onDone(void handleDone()) { |
- this.handleDone = handleDone == null ? _defaultDone: handleDone; |
+ this.handleDone = handleDone == null ? _defaultDone : handleDone; |
} |
void pause([Future resumeSignal]) {} |
@@ -40,15 +42,16 @@ class MyStreamSubscription<T> implements StreamSubscription<T> { |
} |
main() { |
- var transformer = new StreamTransformer<int, String> ( |
- (stream, cancelOnError) => new MyStreamSubscription(stream, cancelOnError)); |
+ var transformer = new StreamTransformer<int, String>( |
+ (stream, cancelOnError) => |
+ new MyStreamSubscription(stream, cancelOnError)); |
var controller = new StreamController(sync: true); |
var stream = controller.stream; |
var transformed = stream.transform(transformer); |
var handleData = (String _) => 499; |
- var handleError = (e,st) => 42; |
+ var handleError = (e, st) => 42; |
var handleDone = () => 99; |
var subscription = |