reactor.core.publisher

接口 Timed<T>

所有超级接口:

java.util.function.Supplier<T>

public interface Timed<T>
extends java.util.function.Supplier<T>

作者:

Simon Baslé

方法概要

限定符和类型	方法和说明
java.time.Duration	elapsed() Get the elapsed Duration since the previous onNext (or onSubscribe in case this represents the first onNext).
java.time.Duration	elapsedSinceSubscription() Get the elapsed Duration since the subscription (onSubscribe signal).
T	get() Get the value wrapped by this Timed.
java.time.Instant	timestamp() Get the timestamp of the emission of this timed onNext, as an Instant.

方法详细资料

get

T get()

Get the value wrapped by this Timed.

指定者:

get 在接口中 java.util.function.Supplier<T>

返回:

the onNext value that was timed

elapsed

java.time.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.

返回:

the elapsed Duration since the previous onNext

elapsedSinceSubscription

java.time.Duration elapsedSinceSubscription()

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

返回:

the elapsed Duration since subscription

timestamp

java.time.Instant timestamp()

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

返回:

the epoch timestamp Instant for this timed onNext