這個 RxBus 穩如老狗

時間 2019-11-07

標籤這個 rxbus 简体版

原文原文鏈接

Download

Gradle:java

implementation "com.blankj:rxbus:1.1"
複製代碼

How to use

非粘性事件

註冊事件

public class YourActivity extends Activity {
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 註冊 String 類型事件
        RxBus.getDefault().subscribe(this, new RxBus.Callback<String>() {
            @Override
            public void onEvent(String s) {
                Log.e("eventTag", s);
            }
        });

        // 註冊帶 tag 爲 "my tag" 的 String 類型事件
        RxBus.getDefault().subscribe(this, "my tag", new RxBus.Callback<String>() {
            @Override
            public void onEvent(String s) {
                Log.e("eventTag", s);
            }
        });
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        // 註銷
        RxBus.getDefault().unregister(this);
    }
}
複製代碼

發送事件

// 發送 String 類型事件
RxBus.getDefault().post("without tag");

// 發送帶 tag 爲 "my tag" 的 String 類型事件
RxBus.getDefault().post("with tag", "my tag");
複製代碼

粘性事件（也就是先發送事件，在以後註冊的時候便會收到以前發送的事件）

發送事件

// 發送 String 類型的粘性事件
RxBus.getDefault().postSticky("without tag");

// 發送帶 tag 爲 "my tag" 的 String 類型的粘性事件
RxBus.getDefault().postSticky("with tag", "my tag");
複製代碼

註冊事件

public class YourActivity extends Activity {
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 註冊 String 類型事件
        RxBus.getDefault().subscribeSticky(this, new RxBus.Callback<String>() {
            @Override
            public void onEvent(String s) {
                Log.e("eventTag", s);
            }
        });

        // 註冊帶 tag 爲 "my tag" 的 String 類型事件
        RxBus.getDefault().subscribeSticky(this, "my tag", new RxBus.Callback<String>() {
            @Override
            public void onEvent(String s) {
                Log.e("eventTag", s);
            }
        });
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        // 註銷
        RxBus.getDefault().unregister(this);
    }
}
複製代碼

Nice wrap

若是用到事件總線的地方比較多，那麼能夠把事件總線的使用放到一個 Manager 中使用，好比我 Demo 中作的封裝以下所示：git

public class RxBusManager {

    private static final String MY_TAG = "MY_TAG";

    public static void subscribeRxBusManagerActivity(final RxBusManagerActivity activity){
        RxBus.getDefault().subscribe(activity, new RxBus.Callback<String>() {
            @Override
            public void onEvent(String s) {
                activity.updateText("without " + s);
            }
        });

        RxBus.getDefault().subscribe(activity, MY_TAG, new RxBus.Callback<String>() {
            @Override
            public void onEvent(String s) {
                activity.updateText("with " + s);
            }
        });
    }

    public static void postToRxBusManagerActivity(final String event) {
        RxBus.getDefault().post(event);
    }

    public static void postWithMyTagToRxBusManagerActivity(final String event) {
        RxBus.getDefault().post(event, MY_TAG);
    }

    public static void postStickyToRxBusManagerActivity(final String event) {
        RxBus.getDefault().postSticky(event);
    }

    public static void postStickyWithMyTagToRxBusManagerActivity(final String event) {
        RxBus.getDefault().postSticky(event, MY_TAG);
    }

    public static void unregisterRxBusManagerActivity(final RxBusManagerActivity activity) {
        RxBus.getDefault().unregister(activity);
    }
}
複製代碼