Skip to content

Commit b69ca2f

Browse files
committed
Add dispose for websocket client and ping controller
1 parent fe89643 commit b69ca2f

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

packages/stream_core/lib/src/ws/client/web_socket_client.dart

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,12 @@ class WebSocketClient implements WebSocketEngineListener, WebSocketPingClient {
8181

8282
engine.disconnect(code.code, source.toString());
8383
}
84+
85+
void dispose() {
86+
pingController.dispose();
87+
_connectionStateStreamController.close();
88+
_events.close();
89+
}
8490
//#endregion
8591

8692
//#region WebSocketEngineListener

packages/stream_core/lib/src/ws/client/web_socket_ping_controller.dart

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,11 @@ class WebSocketPingController {
5959
void _cancelPongTimeoutTimer() {
6060
_pongTimeoutTimer?.cancel();
6161
}
62+
63+
void dispose() {
64+
_pongTimeoutTimer?.cancel();
65+
_pingTimer?.cancel();
66+
}
6267
}
6368

6469
abstract interface class WebSocketPingClient {

0 commit comments

Comments
 (0)