java 示例Otto事件总线提供程序

Posted 2021-05-08

package com.foo.bar.utils;

import android.os.Handler;
import android.os.Looper;

import com.squareup.otto.Bus;
import com.squareup.otto.ThreadEnforcer;


/**
 * Maintains a singleton instance for obtaining the bus. Ideally this would be replaced with a more efficient means such as through
 * injection directly into interested classes.
 */
public final class BusProvider {

    private static final MainPostingBus BUS = new MainPostingBus();

    public static MainPostingBus getInstance() {
        return BUS;
    }

    private BusProvider() {}

    public static class MainPostingBus extends Bus {

        private final Handler mainThread = new Handler( Looper.getMainLooper() );

        public MainPostingBus() {
            super( ThreadEnforcer.ANY );
        }

        @Override
        public void post( final Object event ) {
            if ( Looper.myLooper() == Looper.getMainLooper() ) {
                super.post( event );
            }
            else {
                mainThread.post( new Runnable() {
                    @Override
                    public void run() {
                        post( event );
                    }
                });
            }
        }
    }
}