@override Future<void> send(List<int> bytes) async { final s = _socket; if (s == null || _closed) { throw StateError('TcpModbusByteTransport not open'); } s.add(bytes); await s.flush(); }