Source
void onDisconnected() {
clearProcessors();
_responses.forEach((id, resp) {
resp._close();
});
_responses.clear();
_responses[0] = _subscription;
}
void onDisconnected() {
clearProcessors();
_responses.forEach((id, resp) {
resp._close();
});
_responses.clear();
_responses[0] = _subscription;
}