Lucas Albuquerque

[email protected]

Observable.from(lifeStream()) .doOnSubscribe { takeItEasy() } .doOnNext { event -> learnFrom(event) } .subscribe( { feelGrateful() }, { tryAgain(it) }