Wrap unsafe EventSink

rostopira · web-flow · commit 6701ef28a33d · 2019-05-17T11:04:48.000+03:00
diff --git a/android/src/main/java/com/cloudwebrtc/webrtc/DataChannelObserver.java b/android/src/main/java/com/cloudwebrtc/webrtc/DataChannelObserver.java
@@ -5,6 +5,7 @@
 
 import org.webrtc.DataChannel;
 import io.flutter.plugin.common.EventChannel;
+import com.cloudwebrtc.webrtc.utils.AnyThreadSink;
 import com.cloudwebrtc.webrtc.utils.ConstraintsMap;
 
 class DataChannelObserver implements DataChannel.Observer, EventChannel.StreamHandler {
@@ -43,7 +44,7 @@ private String dataChannelStateString(DataChannel.State dataChannelState) {
 
     @Override
     public void onListen(Object o, EventChannel.EventSink sink) {
-        eventSink = sink;
+        eventSink = new AnyThreadSink(sink);
     }
 
     @Override
