Package se.fortnox.reactivewizard.metrics

Class PublisherMetrics

java.lang.Object

se.fortnox.reactivewizard.metrics.PublisherMetrics

public class PublisherMetrics
extends Object

Wrapper of Dropwizard metrics framework for use with observers.

Method Summary

Modifier and Type	Method	Description
static PublisherMetrics	get(String name)
<T> org.reactivestreams.Publisher<T>	measure(org.reactivestreams.Publisher<T> publisher)
<T> org.reactivestreams.Publisher<T>	measure(org.reactivestreams.Publisher<T> publisher, Consumer<Long> callback)
<T> reactor.core.publisher.Flux<T>	measure(reactor.core.publisher.Flux<T> publisher)
<T> reactor.core.publisher.Mono<T>	measure(reactor.core.publisher.Mono<T> publisher)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

get

public static PublisherMetrics get(String name)

measure

public <T> org.reactivestreams.Publisher<T> measure(org.reactivestreams.Publisher<T> publisher)

measure

public <T> reactor.core.publisher.Mono<T> measure(reactor.core.publisher.Mono<T> publisher)

measure

public <T> reactor.core.publisher.Flux<T> measure(reactor.core.publisher.Flux<T> publisher)

measure

public <T> org.reactivestreams.Publisher<T> measure(org.reactivestreams.Publisher<T> publisher,
 Consumer<Long> callback)