Class ReactorUtils
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic <T> reactor.core.publisher.Flux<T>
withSentry
(@NotNull reactor.core.publisher.Flux<T> flux) static <T> reactor.core.publisher.Mono<T>
withSentry
(@NotNull reactor.core.publisher.Mono<T> mono) static <T> reactor.core.publisher.Flux<T>
withSentryHub
(@NotNull reactor.core.publisher.Flux<T> flux, @NotNull IHub hub) static <T> reactor.core.publisher.Mono<T>
withSentryHub
(@NotNull reactor.core.publisher.Mono<T> mono, @NotNull IHub hub) static <T> reactor.core.publisher.Flux<T>
withSentryNewMainHubClone
(@NotNull reactor.core.publisher.Flux<T> flux) Writes a new SentryIHub
cloned from the main hub to theContext
and usesThreadLocalAccessor
to propagate it.static <T> reactor.core.publisher.Mono<T>
withSentryNewMainHubClone
(@NotNull reactor.core.publisher.Mono<T> mono) Writes a new SentryIHub
cloned from the main hub to theContext
and usesThreadLocalAccessor
to propagate it.
-
Constructor Details
-
ReactorUtils
public ReactorUtils()
-
-
Method Details
-
withSentry
@Experimental public static <T> reactor.core.publisher.Mono<T> withSentry(@NotNull @NotNull reactor.core.publisher.Mono<T> mono) Writes the current SentryIHub
to theContext
and usesThreadLocalAccessor
to propagate it.This requires - reactor.core.publisher.Hooks#enableAutomaticContextPropagation() to be enabled - having `io.micrometer:context-propagation:1.0.2+` (provided by Spring Boot 3.0.3+) - having `io.projectreactor:reactor-core:3.5.3+` (provided by Spring Boot 3.0.3+)
-
withSentryNewMainHubClone
@Experimental public static <T> reactor.core.publisher.Mono<T> withSentryNewMainHubClone(@NotNull @NotNull reactor.core.publisher.Mono<T> mono) Writes a new SentryIHub
cloned from the main hub to theContext
and usesThreadLocalAccessor
to propagate it.This requires - reactor.core.publisher.Hooks#enableAutomaticContextPropagation() to be enabled - having `io.micrometer:context-propagation:1.0.2+` (provided by Spring Boot 3.0.3+) - having `io.projectreactor:reactor-core:3.5.3+` (provided by Spring Boot 3.0.3+)
-
withSentryHub
@Experimental public static <T> reactor.core.publisher.Mono<T> withSentryHub(@NotNull @NotNull reactor.core.publisher.Mono<T> mono, @NotNull @NotNull IHub hub) Writes the given SentryIHub
to theContext
and usesThreadLocalAccessor
to propagate it.This requires - reactor.core.publisher.Hooks#enableAutomaticContextPropagation() to be enabled - having `io.micrometer:context-propagation:1.0.2+` (provided by Spring Boot 3.0.3+) - having `io.projectreactor:reactor-core:3.5.3+` (provided by Spring Boot 3.0.3+)
-
withSentry
@Experimental public static <T> reactor.core.publisher.Flux<T> withSentry(@NotNull @NotNull reactor.core.publisher.Flux<T> flux) Writes the current SentryIHub
to theContext
and usesThreadLocalAccessor
to propagate it.This requires - reactor.core.publisher.Hooks#enableAutomaticContextPropagation() to be enabled - having `io.micrometer:context-propagation:1.0.2+` (provided by Spring Boot 3.0.3+) - having `io.projectreactor:reactor-core:3.5.3+` (provided by Spring Boot 3.0.3+)
-
withSentryNewMainHubClone
@Experimental public static <T> reactor.core.publisher.Flux<T> withSentryNewMainHubClone(@NotNull @NotNull reactor.core.publisher.Flux<T> flux) Writes a new SentryIHub
cloned from the main hub to theContext
and usesThreadLocalAccessor
to propagate it.This requires - reactor.core.publisher.Hooks#enableAutomaticContextPropagation() to be enabled - having `io.micrometer:context-propagation:1.0.2+` (provided by Spring Boot 3.0.3+) - having `io.projectreactor:reactor-core:3.5.3+` (provided by Spring Boot 3.0.3+)
-
withSentryHub
@Experimental public static <T> reactor.core.publisher.Flux<T> withSentryHub(@NotNull @NotNull reactor.core.publisher.Flux<T> flux, @NotNull @NotNull IHub hub) Writes the given SentryIHub
to theContext
and usesThreadLocalAccessor
to propagate it.This requires - reactor.core.publisher.Hooks#enableAutomaticContextPropagation() to be enabled - having `io.micrometer:context-propagation:1.0.2+` (provided by Spring Boot 3.0.3+) - having `io.projectreactor:reactor-core:3.5.3+` (provided by Spring Boot 3.0.3+)
-