java.lang.Object
org.neo4j.driver.internal.observation.util.ObservationUtil
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic void
observe
(Observation observation, Runnable runnable) static <T> T
observe
(Observation observation, Supplier<T> supplier) static <T> CompletionStage
<T> observeAsync
(Observation observation, Supplier<CompletionStage<T>> supplier) static <T> CompletionStage
<T> observeAsyncStarted
(Observation observation, Supplier<CompletionStage<T>> supplier) static <T> org.reactivestreams.Publisher
<T> observeStreams
(Observation observation, org.reactivestreams.Publisher<T> publisher) static <T> org.reactivestreams.Publisher
<T> observeStreams
(Observation observation, org.reactivestreams.Publisher<T> publisher, boolean startOnRequest, boolean stopOnCancel) static <T> org.reactivestreams.Publisher
<T> observeStreamsWithoutStart
(Observation observation, org.reactivestreams.Publisher<T> publisher, boolean stopOnCancel) static <T> T
scoped
(DriverObservationProvider observationProvider, Observation observation, Supplier<T> supplier)
-
Constructor Details
-
ObservationUtil
public ObservationUtil()
-
-
Method Details
-
observe
-
observe
-
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)
-