File tree Expand file tree Collapse file tree 1 file changed +11
-3
lines changed
Expand file tree Collapse file tree 1 file changed +11
-3
lines changed Original file line number Diff line number Diff line change @@ -22,6 +22,9 @@ class RTCDataChannelWeb extends RTCDataChannel {
2222 _messageController.add (msg);
2323 onMessage? .call (msg);
2424 });
25+ _jsDc.addEventListener ('bufferedamountlow' , (_) {
26+ onBufferedAmountLow? .call (bufferedAmount ?? 0 );
27+ });
2528 }
2629
2730 final html.RtcDataChannel _jsDc;
@@ -39,10 +42,15 @@ class RTCDataChannelWeb extends RTCDataChannel {
3942 @override
4043 int ? get bufferedAmount => _jsDc.bufferedAmount;
4144
45+ @override
46+ set bufferedAmountLowThreshold (int ? bufferedAmountLowThreshold) {
47+ _jsDc.bufferedAmountLowThreshold = bufferedAmountLowThreshold;
48+ }
49+
4250 final _stateChangeController =
43- StreamController <RTCDataChannelState >.broadcast (sync : true );
51+ StreamController <RTCDataChannelState >.broadcast (sync : true );
4452 final _messageController =
45- StreamController <RTCDataChannelMessage >.broadcast (sync : true );
53+ StreamController <RTCDataChannelMessage >.broadcast (sync : true );
4654
4755 Future <RTCDataChannelMessage > _parse (dynamic data) async {
4856 if (data is String ) return RTCDataChannelMessage (data);
@@ -72,4 +80,4 @@ class RTCDataChannelWeb extends RTCDataChannel {
7280 _jsDc.close ();
7381 return Future .value ();
7482 }
75- }
83+ }
You can’t perform that action at this time.
0 commit comments