openStream method

@override Future<MuxedStream> openStream(Context context)

Creates a new stream.

Implementation

@override
Future<MuxedStream> openStream(Context context) async {
  if (isClosed) throw StateError('$id: connection closed');
  // Spec: stream channels have an empty label and are negotiated in-band.
  final channel = _pc.createDataChannel('');
  await channel.opened.timeout(const Duration(seconds: 10));
  return _track(WebRtcStream(channel, this, Direction.outbound));
}