Channel<O, I> constructor

Channel<O, I>({ required String name, })

Implementation

Channel({
  required this.name,
}) {
  _connect().then((value) => null);

  _dataMessages = _listenToDataMessage().asBroadcastStream();

  _startListenOnMsgs();

  _replyMessages =
      _dataMessages.where((event) => event.isReply).asBroadcastStream();
}