These are chat archives for ReactiveX/RxJava

Feb 2017
Vojtech Polivka
Feb 24 2017 14:15
is there a subsrciber class without "onCompleted()"? i am dealing with infinite streams here
David Karnok
Feb 24 2017 16:45
Just implement onCompleted() as an empty method.
Feb 24 2017 20:03
This might be stupid, but how can I make an Observable that adds new subs to a list so that if it's currently processing it doesn't try to reprocess after the original process is over.