Commit a4e6c32f authored by Chunchi Che's avatar Chunchi Che

optimize stream.ts

parent 129a7a01
...@@ -27,7 +27,8 @@ export class WebSocketStream { ...@@ -27,7 +27,8 @@ export class WebSocketStream {
}; };
ws.onclose = () => { ws.onclose = () => {
console.info("Websocket closed."); console.info("Websocket closed.");
controller.close(); // 下面这行注释掉,因为虽然websocket关掉了,但是已经收到的数据可能还在处理中
// controller.close();
}; };
}, },
pull(_) { pull(_) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment