linuxerwang
diff --git a/‎android/src/main/java/com/cloudwebrtc/webrtc/utils/AnyThreadResult.java
Lines changed: 12 additions & 6 deletions b/‎android/src/main/java/com/cloudwebrtc/webrtc/utils/AnyThreadResult.java
Lines changed: 12 additions & 6 deletions
diff --git a/‎android/src/main/java/com/cloudwebrtc/webrtc/utils/AnyThreadSink.java
Lines changed: 15 additions & 9 deletions b/‎android/src/main/java/com/cloudwebrtc/webrtc/utils/AnyThreadSink.java
Lines changed: 15 additions & 9 deletions
@@ -7,26 +7,32 @@
 
 public final class AnyThreadResult implements MethodChannel.Result {
     final private MethodChannel.Result result;
+    final private Handler handler = new Handler(Looper.getMainLooper());
 
     public AnyThreadResult(MethodChannel.Result result) {
         this.result = result;
     }
 
     @Override
     public void success(Object o) {
-        final Handler handler = new Handler(Looper.getMainLooper());
-        handler.post(()->result.success(o));
+        post(()->result.success(o));
     }
 
     @Override
     public void error(String s, String s1, Object o) {
-        final Handler handler = new Handler(Looper.getMainLooper());
-        handler.post(()->result.error(s, s1, o));
+        post(()->result.error(s, s1, o));
     }
 
     @Override
     public void notImplemented() {
-        final Handler handler = new Handler(Looper.getMainLooper());
-        handler.post(result::notImplemented);
+        post(result::notImplemented);
+    }
+
+    private void post(Runnable r) {
+        if(Looper.getMainLooper() == Looper.myLooper()){
+            r.run();
+        }else{
+            handler.post(r);
+        }
     }
 }
@@ -6,27 +6,33 @@
 import io.flutter.plugin.common.EventChannel;
 
 public final class AnyThreadSink implements EventChannel.EventSink {
-    private final EventChannel.EventSink eventSink;
-    
+    final private EventChannel.EventSink eventSink;
+    final private Handler handler = new Handler(Looper.getMainLooper());
+
     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));
+        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));
+        post(()->eventSink.error(s, s1, o));
     }
 
     @Override
     public void endOfStream() {
-        final Handler handler = new Handler(Looper.getMainLooper());
-        handler.post(eventSink::endOfStream);
+        post(eventSink::endOfStream);
+    }
+
+    private void post(Runnable r) {
+        if(Looper.getMainLooper() == Looper.myLooper()){
+            r.run();
+        }else{
+            handler.post(r);
+        }
     }
 }