| OLD | NEW |
| 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 import 'dart:async'; | 5 import 'dart:async'; |
| 6 | 6 |
| 7 import 'package:async/async.dart'; | 7 import 'package:async/async.dart'; |
| 8 | 8 |
| 9 import 'src/guarantee_channel.dart'; | 9 import 'src/guarantee_channel.dart'; |
| 10 import 'src/stream_channel_transformer.dart'; | 10 import 'src/stream_channel_transformer.dart'; |
| 11 | 11 |
| 12 export 'src/delegating_stream_channel.dart'; | 12 export 'src/delegating_stream_channel.dart'; |
| 13 export 'src/disconnector.dart'; |
| 13 export 'src/isolate_channel.dart'; | 14 export 'src/isolate_channel.dart'; |
| 14 export 'src/json_document_transformer.dart'; | 15 export 'src/json_document_transformer.dart'; |
| 15 export 'src/multi_channel.dart'; | 16 export 'src/multi_channel.dart'; |
| 16 export 'src/stream_channel_completer.dart'; | 17 export 'src/stream_channel_completer.dart'; |
| 17 export 'src/stream_channel_controller.dart'; | 18 export 'src/stream_channel_controller.dart'; |
| 18 export 'src/stream_channel_transformer.dart'; | 19 export 'src/stream_channel_transformer.dart'; |
| 19 | 20 |
| 20 /// An abstract class representing a two-way communication channel. | 21 /// An abstract class representing a two-way communication channel. |
| 21 /// | 22 /// |
| 22 /// Users should consider the [stream] emitting a "done" event to be the | 23 /// Users should consider the [stream] emitting a "done" event to be the |
| (...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 138 | 139 |
| 139 StreamChannel<T> transformSink(StreamSinkTransformer<T, T> transformer) => | 140 StreamChannel<T> transformSink(StreamSinkTransformer<T, T> transformer) => |
| 140 changeSink(transformer.bind); | 141 changeSink(transformer.bind); |
| 141 | 142 |
| 142 StreamChannel<T> changeStream(Stream<T> change(Stream<T> stream)) => | 143 StreamChannel<T> changeStream(Stream<T> change(Stream<T> stream)) => |
| 143 new StreamChannel(change(stream), sink); | 144 new StreamChannel(change(stream), sink); |
| 144 | 145 |
| 145 StreamChannel<T> changeSink(StreamSink<T> change(StreamSink<T> sink)) => | 146 StreamChannel<T> changeSink(StreamSink<T> change(StreamSink<T> sink)) => |
| 146 new StreamChannel(stream, change(sink)); | 147 new StreamChannel(stream, change(sink)); |
| 147 } | 148 } |
| OLD | NEW |