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 |