reactor.core.publisher

Class MonoCancelOn<T>

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoSource<T,T>

reactor.core.publisher.MonoCancelOn<T>

All Implemented Interfaces:

org.reactivestreams.Publisher<T>, Receiver

public class MonoCancelOn<T>
extends MonoSource<T,T>

Field Summary

Fields inherited from class reactor.core.publisher.MonoSource

source

Constructor Summary

Constructors

Constructor and Description
MonoCancelOn(org.reactivestreams.Publisher<T> source, Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super T> s) Default is delegating and decorating with Mono API

Methods inherited from class reactor.core.publisher.MonoSource

toString, upstream, wrap

Methods inherited from class reactor.core.publisher.Mono

and, as, awaitOnSubscribe, block, block, blockMillis, cache, cancelOn, cast, compose, concatWith, create, defaultIfEmpty, defer, delay, delayMillis, delayMillis, delaySubscription, delaySubscription, delaySubscriptionMillis, delaySubscriptionMillis, dematerialize, doAfterTerminate, doOnCancel, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, empty, error, filter, first, first, flatMap, flatMap, flatMapIterable, flux, from, fromCallable, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, map, mapError, mapError, mapError, materialize, mergeWith, never, ofType, onAssembly, onTerminateDetach, or, otherwise, otherwise, otherwise, otherwiseIfEmpty, otherwiseReturn, otherwiseReturn, otherwiseReturn, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, then, then, then, then, thenMany, thenMany, timeout, timeout, timeout, timeout, timeoutMillis, timeoutMillis, timeoutMillis, timeoutMillis, timestamp, timestamp, toFuture, transform, using, using, when, when, when, when, when, when, when, when, when, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, zip, zip

Methods inherited from class java.lang.Object

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

Constructor Detail

MonoCancelOn

public MonoCancelOn(org.reactivestreams.Publisher<T> source,
                    Scheduler scheduler)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super T> s)

Description copied from class: MonoSource

Default is delegating and decorating with Mono API

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>

Overrides:

subscribe in class MonoSource<T,T>