@override Future stop() async { await transport.close(); _state = _State.init; _connected = false; _listening = false; notifyListeners(); transport.layers.clear(); }