reactor.netty

Class FutureMono

java.lang.Object

reactor.core.publisher.Mono<Void>

reactor.netty.FutureMono

All Implemented Interfaces:

Publisher<Void>, CorePublisher<Void>

public abstract class FutureMono
extends Mono<Void>

Convert Netty Future into void Mono.

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
FutureMono()

Method Summary

Modifier and Type	Method and Description
static <F extends Future<Void>> Mono<Void>	deferFuture(Supplier<F> deferredFuture) Convert a supplied Future for each subscriber into Mono.
static <F extends Future<Void>> Mono<Void>	from(F future) Convert a Future into Mono.

Methods inherited from class reactor.core.publisher.Mono

and, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, mapNotNull, materialize, mergeWith, metrics, name, never, ofType, onAssembly, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, share, single, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, tap, tap, tap, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, when, when, whenDelayError, whenDelayError, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipWhen, zipWhen, zipWith, zipWith

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FutureMono

public FutureMono()

Method Detail

from

public static <F extends Future<Void>> Mono<Void> from(F future)

Convert a Future into Mono. Mono.subscribe(Subscriber) will bridge to Future.addListener(GenericFutureListener).

Type Parameters:

F - the future type

Parameters:

future - the future to convert from

Returns:

A Mono forwarding Future success or failure

deferFuture

public static <F extends Future<Void>> Mono<Void> deferFuture(Supplier<F> deferredFuture)

Convert a supplied Future for each subscriber into Mono. Mono.subscribe(Subscriber) will bridge to Future.addListener(GenericFutureListener).

Type Parameters:

F - the future type

Parameters:

deferredFuture - the future to evaluate and convert from

Returns:

A Mono forwarding Future success or failure