Chromium Code Reviews| 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; |