引用线上库

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();

    }