1、创建被观察者Observable
Observable ob= Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//subscriber主要用来发射数据
subscriber.onNext("sss");
subscriber.onCompleted();
}
});
2、创建观察者
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
©著作权归作者所有,转载或内容合作请联系作者
