Warn when adding something to a closed sink and improve documentation

sdk/lib/async/stream_transformers.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of dart.async;
 
 /**
  * Wraps an [_EventSink] so it exposes only the [EventSink] interface.
  */
 class _EventSinkWrapper<T> implements EventSink<T> {
@@ skipping 191 matching lines @@
  * Wraps handlers (from [StreamTransformer.fromHandlers]) into an `EventSink`.
  *
  * This way we can reuse the code from [_StreamSinkTransformer].
  */
 class _HandlerEventSink<S, T> implements EventSink<S> {
   final _TransformDataHandler<S, T> _handleData;
   final _TransformErrorHandler<T> _handleError;
   final _TransformDoneHandler<T> _handleDone;
 
   /// The output sink where the handlers should send their data into.
   final EventSink<T> _sink;

[Lasse Reichstein Nielsen, 2017/04/26 08:26:19]

Make this field non-final and set it to null when you close.
Then change _isClosed to 
  bool get _isClosed => _sink == null;

That saves one field.

[floitsch, 2017/05/01 16:46:25]

Done.

+  bool _isClosed = false;
 
   _HandlerEventSink(
       this._handleData, this._handleError, this._handleDone, this._sink);
 
   void add(S data) {
+    if (_isClosed) throw new StateError("Sink is closed");
     if (_handleData != null) {
       _handleData(data, _sink);
     } else {
       _sink.add(data as T);
     }
   }
 
   void addError(Object error, [StackTrace stackTrace]) {
+    if (_isClosed) throw new StateError("Sink is closed");
     if (_handleError != null) {
       _handleError(error, stackTrace, _sink);
     } else {
       _sink.addError(error, stackTrace);
     }
   }
 
   void close() {

[Lasse Reichstein Nielsen, 2017/04/26 08:26:19]

We should probably bail out here if the sink is already closed.
So:
  if (_isClosed) return;

[floitsch, 2017/05/01 16:46:25]

Realized the same thing.
done.

+    _isClosed = true;
     if (_handleDone != null) {
       _handleDone(_sink);
     } else {
       _sink.close();
     }
   }
 }
 
 /**
  * A StreamTransformer that transformers events with the given handlers.
@@ skipping 56 matching lines @@
   StreamSubscription<T> listen(void onData(T event),
       {Function onError, void onDone(), bool cancelOnError}) {
     cancelOnError = identical(true, cancelOnError);
     StreamSubscription<T> result = _transformer(_stream, cancelOnError);
     result.onData(onData);
     result.onError(onError);
     result.onDone(onDone);
     return result;
   }
 }