RxJava与RxAndroid

compile 'io.reactivex:rxjava:1.1.6'
compile 'io.reactivex:rxandroid:1.2.1'

public class MainActivity extends AppCompatActivity {

private TextView textView;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
textView = (TextView) findViewById(R.id.textView);

//创建一个“可观察的”
Observable<String> observable = Observable.create(onSubscribe);
//设置在主线程中执行
observable.observeOn(AndroidSchedulers.mainThread());
//分发订阅消息
observable.subscribe(stringSubscriber);
observable.subscribe(toastSubscriber);
}

//创建“被订阅者”，发送消息事件
Observable.OnSubscribe onSubscribe = new Observable.OnSubscribe<String>() {

@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello RxAndroid!");
subscriber.onCompleted();
}
};

//创建“订阅者1”，处理消息事件
Subscriber<String> stringSubscriber = new Subscriber<String>() {
@Override
public void onCompleted() {

}

@Override
public void onError(Throwable e) {

}

@Override
public void onNext(String s) {
textView.setText(s);
}
};

//创建“订阅者2”，处理消息事件
Subscriber<String> toastSubscriber = new Subscriber<String>() {
@Override
public void onCompleted() {

}

@Override
public void onError(Throwable e) {

}

@Override
public void onNext(String s) {
Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show();
}
};
}