mop-flutter-sdk/android/src/main/java/com/finogeeks/mop/MopEventStream.java

package com.finogeeks.mop;

import java.util.HashMap;
import java.util.Map;

import io.flutter.plugin.common.EventChannel;


public class MopEventStream  implements EventChannel.StreamHandler {
    EventChannel.EventSink mEventSlink;
    @Override
    public void onListen(Object o, EventChannel.EventSink eventSink) {
        mEventSlink = eventSink;
    }

    @Override
    public void onCancel(Object o) {
        mEventSlink = null;
    }
    public void send(String channel,String event,Object body) {
        if (mEventSlink != null) {
            Map<String,Object> map = new HashMap<>();
            map.put("channel",channel);
            map.put("event",event);
            map.put("body",body);
            mEventSlink.success(map);
        }
    }
}