基于RxJava的替换EventBus的RxBus

package com.android.view; import android.os.Bundle; import android.os.Handler; import android.support.v7.app.AppCompatActivity; import android.widget.TextView; import android.widget.Toast; import rx.Observable; import rx.Subscription; import rx.android.schedulers.AndroidSchedulers; import rx.functions.Action1; import rx.java.bus.RxBus; public class MainActivity extends AppCompatActivity { private TextView main_text; private Observable observable; private Subscription subscription; @Override protected void onResume() { observable = RxBus.getDefault().register(String.class);//注册用户信息事件 super.onResume(); } @Override protected void onStop() { if (subscription != null && !subscription.isUnsubscribed()) subscription.unsubscribe();//如果订阅取消订阅 super.onStop(); } @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); main_text = (TextView) findViewById(R.id.main_text); getTestData(); observable = RxBus.getDefault() .register(String.class); subscription = observable .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Action1<String>() { @Override public void call(String s) { main_text.append(s); } });//接收String类型的数据 //是否没订阅 Toast.makeText(this, !subscription.isUnsubscribed() ? "已经订阅" : "未订阅", Toast.LENGTH_LONG).show(); } /** * 模拟发送数据 * 这个方法可以在项目的任何位置 */ private void getTestData() { Handler handler = new Handler(); handler.postDelayed(new Runnable() { @Override public void run() { //发送消息 RxBus.getDefault().post("woowwo"); } }, 2000); } @Override protected void onDestroy() { super.onDestroy(); } }