Class ObservationUtil

java.lang.Object
org.neo4j.driver.internal.observation.util.ObservationUtil

public final class ObservationUtil extends Object
  • Constructor Details

    • ObservationUtil

      public ObservationUtil()
  • Method Details

    • observe

      public static void observe(Observation observation, Runnable runnable)
    • observe

      public static <T> T observe(Observation observation, Supplier<T> supplier)
    • scoped

      public static <T> T scoped(DriverObservationProvider observationProvider, Observation observation, Supplier<T> supplier)
    • observeAsync

      public static <T> CompletionStage<T> observeAsync(Observation observation, Supplier<CompletionStage<T>> supplier)
    • observeAsyncStarted

      public static <T> CompletionStage<T> observeAsyncStarted(Observation observation, Supplier<CompletionStage<T>> supplier)
    • observeStreamsWithoutStart

      public static <T> org.reactivestreams.Publisher<T> observeStreamsWithoutStart(Observation observation, org.reactivestreams.Publisher<T> publisher, boolean stopOnCancel)
    • observeStreams

      public static <T> org.reactivestreams.Publisher<T> observeStreams(Observation observation, org.reactivestreams.Publisher<T> publisher)
    • observeStreams

      public static <T> org.reactivestreams.Publisher<T> observeStreams(Observation observation, org.reactivestreams.Publisher<T> publisher, boolean startOnRequest, boolean stopOnCancel)