Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Select an option

  • Save martinomburajr/24af97b35bbf023145d26b82b1d64aeb to your computer and use it in GitHub Desktop.

Select an option

Save martinomburajr/24af97b35bbf023145d26b82b1d64aeb to your computer and use it in GitHub Desktop.
/******************** DELAY **************************/
Observable.just("Hello Computation Scheduler")
.delay(1000, TimeUnit.MILLISECONDS)
.subscribe(stringObserver);
//Output
// E/RxJava2:Schedulers:: onSubscribe | main
// E/RxJava2:Schedulers:: onNext | Hello Computation Scheduler
// E/RxJava2:Schedulers:: onNext | RxComputationThreadPool-1
// E/RxJava2:Schedulers:: onComplete | RxComputationThreadPool-1
/******************** END OF DELAY ***************************/
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment