1陪白、創(chuàng)建被觀察者Observable
Observable ob= Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//subscriber主要用來發(fā)射數(shù)據(jù)
subscriber.onNext("sss");
subscriber.onCompleted();
}
});
2、創(chuàng)建觀察者
Observer<String> observer=new Observer<String>() {
@Override
public void onCompleted() {
Log.d(TAG, "onCompleted ");
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String sss) {
Log.d(TAG, "onNext: "+sss);
}
};
3硬纤、被觀察者訂閱觀察者
ob.map(new Func1<String,String>() {
@Override
public String call(String o) {
return o+"nihao";
}
}).subscribe(observer);
}
Fun1接口
最后編輯于 ：2017.12.06 20:24:42
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
