cyclops.companion.reactor

Interface Monos.NestedMono

Enclosing class:

Monos

public static interface Monos.NestedMono

Method Summary

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

Method Detail

reactiveSeq

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

maybe

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

eval

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

future

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

xor

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

reader

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

cyclopsTry

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

javaOptional

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

javaCompletableFuture

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

javaStream

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