@override Future<void> dispose() => mutex.protectWrite(() async { transport.innerTransport.dispose(); protoConnection.dispose(); _disposed = true; });