acceptStream method

@override Future<MuxedStream> acceptStream()

Accepts a stream opened by the other side.

Implementation

@override
Future<MuxedStream> acceptStream() async {
  _logger.fine('[UDXSessionConn $id] acceptStream called.');
  if (_isClosed && _incomingStreamsController.isClosed) {
     _logger.fine('[UDXSessionConn $id] Session closed, cannot accept new streams.');
     throw SocketException('UDX session is closed, cannot accept new streams.');
  }
  final stream = await _incomingStreamsController.stream.first;
  _logger.fine('[UDXSessionConn $id] Accepted stream: ${(stream as UDXP2PStreamAdapter).id()}');
  return stream;
}