write method

@override Future<void> write(List<int> data)

Writes data to the stream.

Implementation

@override
Future<void> write(List<int> data) async {
  _logger.fine('[UDXP2PStreamAdapter ${id()}] write called with ${data.length} bytes. isClosed: $_isClosed');
  if (_isClosed) {
    _logger.fine('[UDXP2PStreamAdapter ${id()}] Stream closed, throwing StateError on write.');
    throw StateError('Stream is closed');
  }
  await _udxStream.add(data is Uint8List ? data : Uint8List.fromList(data));
  _parentConn.notifyActivity();
  _logger.fine('[UDXP2PStreamAdapter ${id()}] Data written to UDXStream.');
}