cyclops.companion.reactor

Interface Fluxs.FluxNested

Enclosing class:

Fluxs

public static interface Fluxs.FluxNested

Method Summary

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

Method Detail

mono

static <T> Nested<ReactorWitness.flux,ReactorWitness.mono,T> mono(reactor.core.publisher.Flux<reactor.core.publisher.Mono<T>> nested)

flux

static <T> Nested<ReactorWitness.flux,ReactorWitness.flux,T> flux(reactor.core.publisher.Flux<reactor.core.publisher.Flux<T>> nested)

reactiveSeq

static <T> Nested<ReactorWitness.flux,Witness.reactiveSeq,T> reactiveSeq(reactor.core.publisher.Flux<ReactiveSeq<T>> nested)

maybe

static <T> Nested<ReactorWitness.flux,Witness.maybe,T> maybe(reactor.core.publisher.Flux<Maybe<T>> nested)

eval

static <T> Nested<ReactorWitness.flux,Witness.eval,T> eval(reactor.core.publisher.Flux<Eval<T>> nested)

future

static <T> Nested<ReactorWitness.flux,Witness.future,T> future(reactor.core.publisher.Flux<Future<T>> nested)

xor

static <S,P> Nested<ReactorWitness.flux,Higher<Witness.xor,S>,P> xor(reactor.core.publisher.Flux<Xor<S,P>> nested)

reader

static <S,T> Nested<ReactorWitness.flux,Higher<Witness.reader,S>,T> reader(reactor.core.publisher.Flux<Reader<S,T>> nested,
                                                                           S defaultValue)

cyclopsTry

static <S extends java.lang.Throwable,P> Nested<ReactorWitness.flux,Higher<Witness.tryType,S>,P> cyclopsTry(reactor.core.publisher.Flux<Try<P,S>> nested)

javaOptional

static <T> Nested<ReactorWitness.flux,Witness.optional,T> javaOptional(reactor.core.publisher.Flux<java.util.Optional<T>> nested)

javaCompletableFuture

static <T> Nested<ReactorWitness.flux,Witness.completableFuture,T> javaCompletableFuture(reactor.core.publisher.Flux<java.util.concurrent.CompletableFuture<T>> nested)

javaStream

static <T> Nested<ReactorWitness.flux,Witness.stream,T> javaStream(reactor.core.publisher.Flux<java.util.stream.Stream<T>> nested)