Create AnyThreadSink.java

rostopira · web-flow · commit 52d13b2e1a8f · 2019-05-17T10:54:18.000+03:00
diff --git a/android/src/main/java/com/cloudwebrtc/webrtc/utils/AnyThreadSink.java b/android/src/main/java/com/cloudwebrtc/webrtc/utils/AnyThreadSink.java
@@ -0,0 +1,32 @@
+package com.cloudwebrtc.webrtc.utils;
+
+import android.os.Handler;
+import android.os.Looper;
+
+import io.flutter.plugin.common.EventChannel;
+
+public final class AnyThreadSink implements EventChannel.EventSink {
+    private final EventChannel.EventSink eventSink;
+    
+    public AnyThreadSink(EventChannel.EventSink eventSink) {
+        this.eventSink = eventSink;
+    }
+    
+    @Override
+    public void success(Object o) {
+        final Handler handler = new Handler(Looper.getMainLooper());
+        handler.post(()->eventSink.success(o));
+    }
+
+    @Override
+    public void error(String s, String s1, Object o) {
+        final Handler handler = new Handler(Looper.getMainLooper());
+        handler.post(()->eventSink.error(s, s1, o));
+    }
+
+    @Override
+    public void endOfStream() {
+        final Handler handler = new Handler(Looper.getMainLooper());
+        handler.post(eventSink::endOfStream);
+    }
+}
