TF-3334 Dispose web socket when close controller
This commit is contained in:
@@ -116,6 +116,9 @@ class WebSocketQueueHandler {
|
|||||||
bool isMessageProcessed(String messageId) => _processedMessageIds.contains(messageId);
|
bool isMessageProcessed(String messageId) => _processedMessageIds.contains(messageId);
|
||||||
|
|
||||||
void dispose() {
|
void dispose() {
|
||||||
|
_messageQueue.clear();
|
||||||
|
_processedMessageIds.clear();
|
||||||
_queueController.close();
|
_queueController.close();
|
||||||
|
_processingLock = null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1030,6 +1030,7 @@ class SearchEmailController extends BaseController
|
|||||||
_deBouncerTime.cancel();
|
_deBouncerTime.cancel();
|
||||||
emailUIActionWorker.dispose();
|
emailUIActionWorker.dispose();
|
||||||
dashBoardActionWorker.dispose();
|
dashBoardActionWorker.dispose();
|
||||||
|
_webSocketQueueHandler?.dispose();
|
||||||
super.onClose();
|
super.onClose();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -149,6 +149,7 @@ class ThreadController extends BaseController with EmailActionController {
|
|||||||
if (PlatformInfo.isWeb) {
|
if (PlatformInfo.isWeb) {
|
||||||
_resizeBrowserStreamSubscription?.cancel();
|
_resizeBrowserStreamSubscription?.cancel();
|
||||||
}
|
}
|
||||||
|
_webSocketQueueHandler?.dispose();
|
||||||
super.onClose();
|
super.onClose();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user