````
@Override
public void subScribeActual(Observer observer) {
Log.d(TAG,"enter ObservableJust subScribeActual");
observer.onSubscribe();
ScalarDisposable sd =new ScalarDisposable(observer,item);
sd.run();
}
````
````
@Override
public void subScribeActual(Observer observer) {
Log.d(TAG,"enter ObservableJust subScribeActual");
observer.onSubscribe();
ScalarDisposable sd =new ScalarDisposable(observer,item);
sd.run();
}
````
本文标题:rxjava-观察者模式
本文链接:https://www.haomeiwen.com/subject/qazqsltx.html
网友评论