Add Server.isClosed and Client.isClosed.

lib/src/peer.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.peer;
 
 import 'dart:async';
 
 import '../error_code.dart' as error_code;
 import 'client.dart';
@@ skipping 24 matching lines @@
 
   /// A stream controller that forwards incoming messages to [_client] if
   /// they're responses.
   final _clientIncomingForwarder = new StreamController(sync: true);
 
   /// A stream controller that forwards outgoing messages from both [_server]
   /// and [_client].
   final _outgoingForwarder = new StreamController(sync: true);
 
   Future get done => _streams.done;
+  bool get isClosed => _streams.isClosed;
 
   /// Creates a [Peer] that reads incoming messages from [incoming] and writes
   /// outgoing messages to [outgoing].
   ///
   /// If [incoming] is a [StreamSink] as well as a [Stream] (for example, a
   /// `WebSocket`), [outgoing] may be omitted.
   ///
   /// Note that the peer won't begin listening to [incoming] until [Peer.listen]
   /// is called.
   Peer(Stream<String> incoming, [StreamSink<String> outgoing]) {
@@ skipping 74 matching lines @@
         // Non-Map and -List messages are ill-formed, so we pass them to the
         // server since it knows how to send error responses.
         _serverIncomingForwarder.add(message);
       }
     });
   }
 
   Future close() =>
       Future.wait([_client.close(), _server.close(), _streams.close()]);
 }