@override Future<void> disconnect() async { if (disconnected) return; disconnected = true; _provider.log.add({'disconnected': true}); await _events.close(); }