reactor.core.publisher

Class MonoElapsed<T>

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoSource<T,Tuple2<java.lang.Long,T>>

reactor.core.publisher.MonoElapsed<T>

All Implemented Interfaces:

org.reactivestreams.Publisher<Tuple2<java.lang.Long,T>>, Fuseable, Receiver

public class MonoElapsed<T>
extends MonoSource<T,Tuple2<java.lang.Long,T>>
implements Fuseable

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Fuseable

Fuseable.ConditionalSubscriber<T>, Fuseable.QueueSubscription<T>, Fuseable.ScalarCallable<T>, Fuseable.SynchronousSubscription<T>

Field Summary

Fields inherited from class reactor.core.publisher.MonoSource

source

Fields inherited from interface reactor.core.Fuseable

ANY, ASYNC, NONE, SYNC, THREAD_BARRIER

Constructor Summary

Constructors

Constructor and Description
MonoElapsed(org.reactivestreams.Publisher<T> source, TimedScheduler scheduler)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super Tuple2<java.lang.Long,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

MonoElapsed

public MonoElapsed(org.reactivestreams.Publisher<T> source,
                   TimedScheduler scheduler)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super Tuple2<java.lang.Long,T>> s)

Description copied from class: MonoSource

Default is delegating and decorating with Mono API

Specified by:

subscribe in interface org.reactivestreams.Publisher<Tuple2<java.lang.Long,T>>

Overrides:

subscribe in class MonoSource<T,Tuple2<java.lang.Long,T>>