OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 part of "dart:async"; | 5 part of "async.dart"; |
6 | 6 |
7 /** | 7 /** |
8 * Wraps an [_EventSink] so it exposes only the [EventSink] interface. | 8 * Wraps an [_EventSink] so it exposes only the [EventSink] interface. |
9 */ | 9 */ |
10 class _EventSinkWrapper<T> implements EventSink<T> { | 10 class _EventSinkWrapper<T> implements EventSink<T> { |
11 _EventSink _sink; | 11 _EventSink _sink; |
12 _EventSinkWrapper(this._sink); | 12 _EventSinkWrapper(this._sink); |
13 | 13 |
14 void add(T data) { | 14 void add(T data) { |
15 _sink._add(data); | 15 _sink._add(data); |
(...skipping 307 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
323 StreamSubscription<T> listen(void onData(T event), | 323 StreamSubscription<T> listen(void onData(T event), |
324 {Function onError, void onDone(), bool cancelOnError}) { | 324 {Function onError, void onDone(), bool cancelOnError}) { |
325 cancelOnError = identical(true, cancelOnError); | 325 cancelOnError = identical(true, cancelOnError); |
326 StreamSubscription<T> result = _onListen(_stream, cancelOnError); | 326 StreamSubscription<T> result = _onListen(_stream, cancelOnError); |
327 result.onData(onData); | 327 result.onData(onData); |
328 result.onError(onError); | 328 result.onError(onError); |
329 result.onDone(onDone); | 329 result.onDone(onDone); |
330 return result; | 330 return result; |
331 } | 331 } |
332 } | 332 } |
OLD | NEW |