OLD | NEW |
(Empty) | |
| 1 >>> (indent 6) |
| 2 identifier__ = identifier_____.identifier___ |
| 3 .transform(new StreamTransformer<TypeArg____, Type_>.fromHandlers( |
| 4 handleData: (TypeName___ arg__, EventSink<Type_> arg_) { |
| 5 ; |
| 6 })) |
| 7 .asBroadcastStream(); |
| 8 <<< |
| 9 identifier__ = identifier_____.identifier___.transform( |
| 10 new StreamTransformer<TypeArg____, Type_>.fromHandlers( |
| 11 handleData: (TypeName___ arg__, EventSink<Type_> arg_) { |
| 12 ; |
| 13 })).asBroadcastStream(); |
| 14 >>> (indent 4) |
| 15 _trigger |
| 16 .then(ut.expectAsync((result) { |
| 17 if (_deferExpectations == null || _deferExpectations == false) { |
| 18 body(result); |
| 19 } else { |
| 20 defer(ut.expectAsync(() => body(result))); |
| 21 } |
| 22 })) |
| 23 .catchError(ut.fail); |
| 24 <<< |
| 25 _trigger.then(ut.expectAsync((result) { |
| 26 if (_deferExpectations == null || _deferExpectations == false) { |
| 27 body(result); |
| 28 } else { |
| 29 defer(ut.expectAsync(() => body(result))); |
| 30 } |
| 31 })).catchError(ut.fail); |
OLD | NEW |