Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private BehaviorSubject<DataObject> dataSubject = BehaviorSubject.create();
- public Observable<DataObject> pendingData() {
- return this.dataSubject.asObservable()
- .doOnNext(data -> {
- // do something with this data that has to be thread save.
- })
- .observeOn(AndroidSchedulers.mainThread());
- }
- public Observable<DataObject> pendingData() {
- return this.dataSubject.asObservable()
- .doOnNext(data -> {
- // do something with this data that has to be thread save.
- })
- .subscribeOn(certainBackgroundScheduler)
- .observeOn(AndroidSchedulers.mainThread());
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement