All Methods Static Methods Default Methods
| Modifier and Type |
Method and Description |
static <S extends java.lang.Throwable,P>
Nested<Higher<Witness.tryType,S>,ReactorWitness.flux,P> |
cyclopsTry(Try<reactor.core.publisher.Flux<P>,S> nested) |
static <T> Nested<Witness.eval,ReactorWitness.flux,T> |
eval(Eval<reactor.core.publisher.Flux<T>> nested) |
static <T> Nested<Witness.future,ReactorWitness.flux,T> |
future(Future<reactor.core.publisher.Flux<T>> nested) |
static <T> Nested<Witness.completableFuture,ReactorWitness.flux,T> |
javaCompletableFuture(java.util.concurrent.CompletableFuture<reactor.core.publisher.Flux<T>> nested) |
static <T> Nested<Witness.optional,ReactorWitness.flux,T> |
javaOptional(java.util.Optional<reactor.core.publisher.Flux<T>> nested) |
static <T> Nested<Witness.stream,ReactorWitness.flux,T> |
javaStream(java.util.stream.Stream<reactor.core.publisher.Flux<T>> nested) |
static <T> Nested<Witness.maybe,ReactorWitness.flux,T> |
maybe(Maybe<reactor.core.publisher.Flux<T>> nested) |
static <T> Nested<Witness.reactiveSeq,ReactorWitness.flux,T> |
reactiveSeq(ReactiveSeq<reactor.core.publisher.Flux<T>> nested) |
static <S,T> Nested<Higher<Witness.reader,S>,ReactorWitness.flux,T> |
reader(Reader<S,reactor.core.publisher.Flux<T>> nested,
S defaultValue) |
static <S,P> Nested<Higher<Witness.xor,S>,ReactorWitness.flux,P> |
xor(Xor<S,reactor.core.publisher.Flux<P>> nested) |