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; }