程序包 | 说明 |
---|---|
reactor.core.publisher |
限定符和类型 | 方法和说明 |
---|---|
Mono<Timed<T>> |
Mono.timed()
为这个
Mono Subscriber.onNext(Object) 添加计时事件,封装到一个 Timed 对象中
Times this Mono Subscriber.onNext(Object) event, encapsulated into a Timed object
that lets downstream consumer look at various time information gathered with nanosecond
resolution using the default clock (Schedulers.parallel() ):
elapsed() : the time in nanoseconds since subscription, as a Duration . |
Flux<Timed<T>> |
Flux.timed()
Times
Subscriber.onNext(Object) events, encapsulated into a Timed object
that lets downstream consumer look at various time information gathered with nanosecond
resolution using the default clock (Schedulers.parallel() ):
elapsed() : the time in nanoseconds since last event, as a Duration . |
Mono<Timed<T>> |
Mono.timed(Scheduler clock)
|
Flux<Timed<T>> |
Flux.timed(Scheduler clock)
|