@@ -0,0 +1,915 @@
+package com.cloudwebrtc.webrtc.utils;%0A%0Aimport android.os.Handler;%0Aimport android.os.Looper;%0A%0Aimport io.flutter.plugin.common.EventChannel;%0A%0Apublic final class AnyThreadSink implements EventChannel.EventSink %7B%0A    private final EventChannel.EventSink eventSink;%0A    %0A    public AnyThreadSink(EventChannel.EventSink eventSink) %7B%0A        this.eventSink = eventSink;%0A    %7D%0A    %0A    @Override%0A    public void success(Object o) %7B%0A        final Handler handler = new Handler(Looper.getMainLooper());%0A        handler.post(()-%3EeventSink.success(o));%0A    %7D%0A%0A    @Override%0A    public void error(String s, String s1, Object o) %7B%0A        final Handler handler = new Handler(Looper.getMainLooper());%0A        handler.post(()-%3EeventSink.error(s, s1, o));%0A    %7D%0A%0A    @Override%0A    public void endOfStream() %7B%0A        final Handler handler = new Handler(Looper.getMainLooper());%0A        handler.post(eventSink::endOfStream);%0A    %7D%0A%7D%0A

Create AnyThreadSink.java