Skip to content

Instantly share code, notes, and snippets.

@jdamcd
Last active September 20, 2015 10:33
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 jdamcd/be60918911f6336cc7a1 to your computer and use it in GitHub Desktop.
Save jdamcd/be60918911f6336cc7a1 to your computer and use it in GitHub Desktop.
Observable<ServiceResult> pollService() {
return Observable.interval(2, TimeUnit.SECONDS)
.take(3)
.flatMap(tick -> fetchResult())
.takeFirst(result -> !result.isProcessing());
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment