Skip to content

Instantly share code, notes, and snippets.

@vamjakuldip

vamjakuldip/ObservableWithDelayItem.kt

Created January 31, 2020 06:36
Show Gist options
  • Save vamjakuldip/df99a37b1f2a8a53fa7caa9534592561 to your computer and use it in GitHub Desktop.
Save vamjakuldip/df99a37b1f2a8a53fa7caa9534592561 to your computer and use it in GitHub Desktop.
Download ZIP
RxJava, Observable With Delay Item example.
Raw
ObservableWithDelayItem.kt
Observable.fromIterable<Int>(Arrays.asList(1, 2, 3))
.zipWith(Observable.interval(200, TimeUnit.MILLISECONDS), BiFunction { item:Int, _:Long -> item })
.subscribe { integers: Int -> Log.d(TAG, "item $integers") }
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment