Advertisement
Guest User

Untitled

a guest
Dec 9th, 2016
66
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.63 KB | None | 0 0
  1. private BehaviorSubject<DataObject> dataSubject = BehaviorSubject.create();
  2.  
  3. public Observable<DataObject> pendingData() {
  4. return this.dataSubject.asObservable()
  5. .doOnNext(data -> {
  6. // do something with this data that has to be thread save.
  7. })
  8. .observeOn(AndroidSchedulers.mainThread());
  9. }
  10.  
  11. public Observable<DataObject> pendingData() {
  12. return this.dataSubject.asObservable()
  13. .doOnNext(data -> {
  14. // do something with this data that has to be thread save.
  15. })
  16. .subscribeOn(certainBackgroundScheduler)
  17. .observeOn(AndroidSchedulers.mainThread());
  18. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement