Index: dart/sdk/lib/io/websocket_impl.dart |
=================================================================== |
--- dart/sdk/lib/io/websocket_impl.dart (revision 40021) |
+++ dart/sdk/lib/io/websocket_impl.dart (working copy) |
@@ -372,6 +372,8 @@ |
_upgrade(request, _protocolSelector) |
.then((WebSocket webSocket) => _controller.add(webSocket)) |
.catchError(_controller.addError); |
+ }, onDone: () { |
+ _controller.close(); |
}); |
return _controller.stream; |