@override Future close() async { if (_state == TransportConnectState.connected) { _normalStop = true; return await _socket?.close(); } }