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 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)