Category "rx-java"

What is this dependency error with Report portal?

I have Cucumber Jbehave Test Automation framework which I am trying to sync up with Report Portal. I updated pom.xml, log4j2.xml and ReportPortal.properties fil

Is it correct to convert a CompletableFuture<Stream<T>> to a Publisher<T>?

To allow multiple iterations on the resulting stream from a CompletableFuture<Stream<String>> I am considering one of the following approaches: Con

How do I check in an operator that current element is last element?

Context: To process a Flowable<Item>, I need to first process the first item and then depending on that either accumulate all items into a single item (re

RxJava- CombineLatest but only fire for one Observable's emission?

Let's say I have two infinite Observables that can emit values at any moment. They combine to create a Observable<ProcessFileEvent>. Observable<Intege