Android 中 RxBus 的使用

implementation 'com.hwangjr.rxbus:rxbus:2.0.0'

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    RxBus.get().register(this);
}

@Override
protected void onDestroy() {
    RxBus.get().unregister(this);
    super.onDestroy();
}

@Produce(
        thread = EventThread.IO,
        tags = {
                @Tag("007")
        }
)
public ArrayList<String> produce02() {
    ArrayList<String> words = new ArrayList<>();
    words.add("好好学习");
    words.add("天天向上");
    return words;
}

@Produce
public String produce01() {
    return "页面初始化加载!";
}

RxBus.get().post("我是新数据");
RxBus.get().post("007","我是新数据(自定义Tag)");

@Subscribe
public void subscribe02(String word) {
    Snackbar.make(getWindow().getDecorView(), word, Snackbar.LENGTH_SHORT)
            .setAction("Action", null).show();
}

@Subscribe(
        thread = EventThread.MAIN_THREAD,
        tags = {
                @Tag("007")
        }
)
public void subscribe03(ArrayList<String> words) {
    Snackbar.make(getWindow().getDecorView(), words.toString(), Snackbar.LENGTH_SHORT)
            .setAction("Action", null).show();
}