Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(418)

Unified Diff: tool/input_sdk/lib/async/stream_transformers.dart

Issue 1953153002: Update dart:async to match the Dart repo. (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: Remove unneeded calls. Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « tool/input_sdk/lib/async/stream_pipe.dart ('k') | tool/input_sdk/lib/async/timer.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: tool/input_sdk/lib/async/stream_transformers.dart
diff --git a/tool/input_sdk/lib/async/stream_transformers.dart b/tool/input_sdk/lib/async/stream_transformers.dart
index b18d226fbe7cc238035a0205f0d76c34e61da123..e0982da4260ec621621a82b526aa21dac87f2be4 100644
--- a/tool/input_sdk/lib/async/stream_transformers.dart
+++ b/tool/input_sdk/lib/async/stream_transformers.dart
@@ -28,7 +28,7 @@ class _EventSinkWrapper<T> implements EventSink<T> {
class _SinkTransformerStreamSubscription<S, T>
extends _BufferingStreamSubscription<T> {
/// The transformer's input sink.
- EventSink _transformerSink;
+ EventSink<S> _transformerSink;
/// The subscription to the input stream.
StreamSubscription<S> _subscription;
@@ -183,8 +183,9 @@ class _BoundSinkStream<S, T> extends Stream<T> {
void onDone(),
bool cancelOnError }) {
cancelOnError = identical(true, cancelOnError);
- StreamSubscription<T> subscription = new _SinkTransformerStreamSubscription(
- _stream, _sinkMapper, onData, onError, onDone, cancelOnError);
+ StreamSubscription<T> subscription =
+ new _SinkTransformerStreamSubscription<S, T>(
+ _stream, _sinkMapper, onData, onError, onDone, cancelOnError);
return subscription;
}
}
@@ -213,10 +214,11 @@ class _HandlerEventSink<S, T> implements EventSink<S> {
_HandlerEventSink(this._handleData, this._handleError, this._handleDone,
this._sink);
- void add(S data) => _handleData(data, _sink);
- void addError(Object error, [StackTrace stackTrace])
- => _handleError(error, stackTrace, _sink);
- void close() => _handleDone(_sink);
+ void add(S data) { _handleData(data, _sink); }
+ void addError(Object error, [StackTrace stackTrace]) {
+ _handleError(error, stackTrace, _sink);
+ }
+ void close() { _handleDone(_sink); }
}
/**
@@ -250,7 +252,7 @@ class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {
/** Default error handler forwards all errors. */
static void _defaultHandleError(error, StackTrace stackTrace,
EventSink sink) {
- sink.addError(error);
+ sink.addError(error, stackTrace);
}
/** Default done handler forwards done. */
« no previous file with comments | « tool/input_sdk/lib/async/stream_pipe.dart ('k') | tool/input_sdk/lib/async/timer.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698