thuutin

// Generate fibonacci sequence using Rxjava 2.
// This is an example to write a stream of events when future events depend on previous events, using reactive programming. 

Flowable.generate(Callable { 0 to 1 }, BiFunction { prev:Pair<Int, Int>, emitter: Emitter<Int> ->
  val next = prev.first + prev.second
  emitter.onNext(prev.second)
  prev.second to next
})
.take(100)
.subscribe {