RTCDataChannelWeb constructor
RTCDataChannelWeb(
- 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);
});
}