rxjava-观察者模式
2021-05-26 本文已影响0人
奔跑吧小马哥
````
@Override
public void subScribeActual(Observer observer) {
Log.d(TAG,"enter ObservableJust subScribeActual");
observer.onSubscribe();
ScalarDisposable sd =new ScalarDisposable(observer,item);
sd.run();
}
````
