Add Server.isClosed and Client.isClosed.

lib/src/two_way_stream.dart

 // Copyright (c) 2014, 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.
 
 library json_rpc_2.two_way_stream;
 
 import 'dart:async';
 import 'dart:convert';
 
 import 'utils.dart';
@@ skipping 20 matching lines @@
   ///
   /// This takes decoded JSON objects.
   final StreamSink _output;
 
   /// Returns a [Future] that completes when the connection is closed.
   ///
   /// This is the same future that's returned by [listen].
   Future get done => _doneCompleter.future;
   final _doneCompleter = new Completer();
 
+  /// Whether the stream has been closed.
+  bool get isClosed => _doneCompleter.isCompleted;
+
   /// Creates a two-way stream.
   ///
   /// [input] and [output] should emit and take (respectively) JSON-encoded
   /// strings.
   ///
   /// [inputName] is used in error messages as the name of the input parameter.
   /// [outputName] is likewise used as the name of the output parameter.
   ///
   /// If [onInvalidInput] is passed, any errors parsing messages from [input]
   /// are passed to it. Otherwise, they're ignored and the input is discarded.
@@ skipping 45 matching lines @@
   /// The returned Future will complete when the input stream is closed. If the
   /// input stream emits an error, that will be piped to the returned Future.
   Future listen(void handleInput(input)) {
     if (_inputSubscription != null) {
       throw new StateError("Can only call $_name.listen once.");
     }
 
     _inputSubscription = _input.listen(handleInput,
         onError: (error, stackTrace) {
       if (_doneCompleter.isCompleted) return;
+      _doneCompleter.completeError(error, stackTrace);
       _output.close();
-      _doneCompleter.completeError(error, stackTrace);
     }, onDone: () {
       if (_doneCompleter.isCompleted) return;
+      _doneCompleter.complete();
       _output.close();
-      _doneCompleter.complete();
     }, cancelOnError: true);
 
     return _doneCompleter.future;
   }
 
   /// Emit [event] on the output stream.
   void add(event) => _output.add(event);
 
   /// Stops listening to the input stream and closes the output stream.
   Future close() {
     if (_inputSubscription == null) {
       throw new StateError("Can't call $_name.close before $_name.listen.");
     }
 
+    _isClosed = true;
     if (!_doneCompleter.isCompleted) _doneCompleter.complete();
 
     var inputFuture = _inputSubscription.cancel();
     // TODO(nweiz): include the output future in the return value when issue
     // 19095 is fixed.
     _output.close();
     return inputFuture == null ? new Future.value() : inputFuture;
   }
 }