Top Methods
reactor.core.publisher

public Interface Timed<T>

extends Supplier<T>
Known Direct Implementers
reactor.core.publisher.FluxTimed.ImmutableTimed
Imports
java.time.Duration, .Instant, java.util.function.Supplier
Author
Simon Baslé

Method Summary

Modifier and TypeMethod and Description
public Duration

Returns:

the elapsed Duration since the previous onNext
elapsed()

Get the elapsed Duration since the previous onNext (or onSubscribe in case this represents the first onNext).

public Duration

Returns:

the elapsed Duration since subscription
elapsedSinceSubscription()

Get the elapsed Duration since the subscription (onSubscribe signal).

public T

Returns:

the onNext value that was timed
get()

Redeclares java.util.function.Supplier.get.

Get the value wrapped by this Timed.
public Instant

Returns:

the epoch timestamp Instant for this timed onNext
timestamp()

Get the timestamp of the emission of this timed onNext, as an Instant.

Method Detail

elapsedback to summary
public 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:Duration

the elapsed Duration since the previous onNext

elapsedSinceSubscriptionback to summary
public Duration elapsedSinceSubscription()

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

Returns:Duration

the elapsed Duration since subscription

getback to summary
public T get()

Redeclares java.util.function.Supplier.get.

Get the value wrapped by this Timed.

Returns:T

the onNext value that was timed

Annotations
@Override
timestampback to summary
public 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:Instant

the epoch timestamp Instant for this timed onNext