These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
new MyTransformer(), new MyAction()calls everywhere in my code and instead create factory methods. So I might have a
RxLoggerclass that has actions related to logging, which you would call like
Operatorswhich contains factory methods for creating custom Transformers, Operators, Functions and Actions. Most of these are generic and aren't associated with any particular data type. I'm trying to get rid of this class but am struggling to come up with a good alternative
withLatestFromlooks right to me, but I haven't used it much
sampledoes not combine the sequences, and does not emit duplicate values from the other subscription if it did not fire since the last click. This might or might not be what you want.
clickStream.withLatestFrom(dataStream, (left, right) -> right).subscribe(parseData)
_instead of click (.net style). I'm used to .net and the poor thing doesnt even have a withLatestFrom, so i was stuck with