createStream method

Future<MessageStreamWriter> createStream({
  1. required Participant to,
  2. required Map<String, dynamic> header,
})

Implementation

Future<MessageStreamWriter> createStream({required Participant to, required Map<String, dynamic> header}) async {
  final streamId = Uuid().v4();

  final completer = Completer<MessageStreamWriter>();
  _streamWriters[streamId] = completer;

  await sendMessage(to: to, type: "stream.open", message: {"stream_id": streamId, "header": header});

  return await completer.future;
}