These are chat archives for ReactiveX/RxJava

Apr 2016
Alon Dolev
Apr 23 2016 15:12
Hi! I used rx.fileutils.* to create an Observable of FileSystemEvents, and I subscribed some simple print function to it. To test this application, I created a blockingObservable and called last() on it. I do not expect this to ever return a value, I just wanted something to block. Because of this last() call , only every other file modification event comes through to the println subscriber. I stepped through the code, and found that the missing events got consumed by the OperatorTakeLasts "call" function. Did I do something wrong? What is going on here? Here is the code: