hxb
2024-02-22 d451118d4be05f180cfe1f99bc5904f74db8cc3f
HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
@@ -112,7 +112,6 @@
    /**
     * 两个主题是否匹配
     *
     * @param desString    字典中的主题
     * @param sourceString 接收到的主题
     * @return
@@ -136,11 +135,10 @@
    /**
     * 事件分发器,分发所有在接口列表中的事件
     *
     * @param topicTag -
     * @param o        -
     * @param topicTag
     * @param o
     */
    public synchronized void post(String topicTag, final Object o) {
    public synchronized void post(String topicTag, @NonNull Object o) {
        try {
            for (String key : EVENT.keySet()) {
                if (!isMatch(key, topicTag)) {
@@ -170,14 +168,14 @@
            }
            //开发分发事件
            for (EventListener listener : ALL_TOPICS_EVENT) {
//                ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
//                    @Override
//                    public void run() {
                ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                if (listener != null) {
                    listener.onMessage(o);
                }
//                    }
//                });
                    }
                });
            }
        } catch (Exception e) {
            LogUtils.e(e.getMessage());
@@ -191,10 +189,8 @@
    public synchronized void filePost() {
        //TODO
    }
    /**
     * 注册所有主题消息的监听
     *
     * @param listener
     */
    public synchronized void registerAllTopicsListener(EventListener listener) {
@@ -210,7 +206,6 @@
    /**
     * 取消所有主题消息的监听
     *
     * @param listener
     */
    public synchronized void removeAllTopicsListener(EventListener listener) {
@@ -229,13 +224,13 @@
        });
    }
    private synchronized void clear() {
    public synchronized void clear() {
        ALL_TOPICS_EVENT.clear();
        EVENT.clear();
//        TYPE.clear();
    }
    private synchronized void release() {
    public synchronized void release() {
        clear();
        ioThread.shutdownNow();
    }