Skip to content

Instantly share code, notes, and snippets.

@sagarpatel288
Forked from mitchtabian/Observable.java
Created January 22, 2021 00:04
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save sagarpatel288/ca643ae6d97be5472c2c3a31812013b8 to your computer and use it in GitHub Desktop.
Save sagarpatel288/ca643ae6d97be5472c2c3a31812013b8 to your computer and use it in GitHub Desktop.
Observable<Task> taskObservable = Observable // create a new Observable object
.fromIterable(DataSource.createTasksList()) // apply 'fromIterable' operator
.subscribeOn(Schedulers.io()) // designate worker thread (background)
.observeOn(AndroidSchedulers.mainThread()); // designate observer thread (main thread)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment