RTCDataChannelWeb constructor

RTCDataChannelWeb(
  1. RtcDataChannel _jsDc
)

Implementation

RTCDataChannelWeb(this._jsDc) {
  stateChangeStream = _stateChangeController.stream;
  messageStream = _messageController.stream;
  _jsDc.onClose.listen((_) {
    _state = RTCDataChannelState.RTCDataChannelClosed;
    _stateChangeController.add(_state);
    onDataChannelState?.call(_state);
  });
  _jsDc.onOpen.listen((_) {
    _state = RTCDataChannelState.RTCDataChannelOpen;
    _stateChangeController.add(_state);
    onDataChannelState?.call(_state);
  });
  _jsDc.onMessage.listen((event) async {
    var msg = await _parse(event.data);
    _messageController.add(msg);
    onMessage?.call(msg);
  });
}