RxJava的事件序列

• Observable.create()

//創建observable被觀察者Observable.create(new Observable.OnSubscribe<String>() {@Overridepublic void call(Subscriber<? super String> subscriber) {subscriber.onNext("hello");//onNext()可以調用多次subscriber.onCompleted();//事件序列結束標記 //subscriber.onError();事件錯誤的標記}}).subscribe(new Observer<String>() {//觀察者@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic void onNext(String s) {}});

• Observable.just()

Observable.just("hello","are you ok ?").subscribe(new Observer<String>() {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic void onNext(String s) {}});

• Observable.from()

String[] array = {"hello","java"};Observable.from(array).subscribe(subscribe);//訂閱者 @Overrideprotected void onDestroy() {super.onDestroy();subscribe.unsubscribe();//銷毀} public Subscriber<String> subscribe = new Subscriber<String>() {@Overridepublic void onStart() {super.onStart();}@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic void onNext(String s) {}}; Observable.from(array).subscribe(new Action1<String>() {@Overridepublic void call(String s) {}}, new Action1<Throwable>() {@Overridepublic void call(Throwable throwable) {}}, new Action0() {@Overridepublic void call() {}});

總結

以上是生活随笔為你收集整理的RxJava 在Android中的应用(二)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。