reactor.core.publisher

Interface Timed<T>

All Superinterfaces:

Supplier<T>

public interface Timed<T>
extends Supplier<T>

Author:

Simon Baslé

Method Summary

Modifier and Type	Method and Description
Duration	elapsed() Get the elapsed Duration since the previous onNext (or onSubscribe in case this represents the first onNext).
Duration	elapsedSinceSubscription() Get the elapsed Duration since the subscription (onSubscribe signal).
T	get() Get the value wrapped by this Timed.
Instant	timestamp() Get the timestamp of the emission of this timed onNext, as an Instant.

Method Detail

get

T get()

Get the value wrapped by this Timed.

Specified by:

get in interface Supplier<T>

Returns:

the onNext value that was timed

elapsed

Duration elapsed()

Get the elapsed Duration since the previous onNext (or onSubscribe in case this represents the first onNext). If possible, nanosecond resolution is used.

Returns:

the elapsed Duration since the previous onNext

elapsedSinceSubscription

Duration elapsedSinceSubscription()

Get the elapsed Duration since the subscription (onSubscribe signal). If possible, nanosecond resolution is used.

Returns:

the elapsed Duration since subscription

timestamp

Instant timestamp()

Get the timestamp of the emission of this timed onNext, as an Instant. It has the same resolution as Instant.ofEpochMilli(long).

Returns:

the epoch timestamp Instant for this timed onNext