Package io.sentry.spring.jakarta.webflux

Class ReactorUtils

java.lang.Object
io.sentry.spring.jakarta.webflux.ReactorUtils
@Experimental public final class ReactorUtils extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactorUtils()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> reactor.core.publisher.Flux<T>
    withSentry(@NotNull reactor.core.publisher.Flux<T> flux)
    Writes the current Sentry IScopes to the Context and uses ThreadLocalAccessor to propagate it.
    static <T> reactor.core.publisher.Mono<T>
    withSentry(@NotNull reactor.core.publisher.Mono<T> mono)
    Writes the current Sentry IScopes to the Context and uses ThreadLocalAccessor to propagate it.
    static <T> reactor.core.publisher.Flux<T>
    withSentryForkedRoots(@NotNull reactor.core.publisher.Flux<T> flux)
    Writes a new Sentry IScopes forked from the main scopes to the Context and uses ThreadLocalAccessor to propagate it.
    static <T> reactor.core.publisher.Mono<T>
    withSentryForkedRoots(@NotNull reactor.core.publisher.Mono<T> mono)
    Writes a new Sentry IScopes forked from the main scopes to the Context and uses ThreadLocalAccessor to propagate it.
    static <T> reactor.core.publisher.Flux<T>
    withSentryScopes(@NotNull reactor.core.publisher.Flux<T> flux, @NotNull IScopes scopes)
    Writes the given Sentry IScopes to the Context and uses ThreadLocalAccessor to propagate it.
    static <T> reactor.core.publisher.Mono<T>
    withSentryScopes(@NotNull reactor.core.publisher.Mono<T> mono, @NotNull IScopes scopes)
    Writes the given Sentry IScopes to the Context and uses ThreadLocalAccessor to propagate it.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactorUtils

      public ReactorUtils()

  • Method Details

    • withSentry

      public static <T> reactor.core.publisher.Mono<T> withSentry(@NotNull @NotNull reactor.core.publisher.Mono<T> mono)
      Writes the current Sentry IScopes to the Context and uses ThreadLocalAccessor 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+)

    • withSentryForkedRoots

      public static <T> reactor.core.publisher.Mono<T> withSentryForkedRoots(@NotNull @NotNull reactor.core.publisher.Mono<T> mono)
      Writes a new Sentry IScopes forked from the main scopes to the Context and uses ThreadLocalAccessor 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+)

    • withSentryScopes

      public static <T> reactor.core.publisher.Mono<T> withSentryScopes(@NotNull @NotNull reactor.core.publisher.Mono<T> mono, @NotNull @NotNull IScopes scopes)
      Writes the given Sentry IScopes to the Context and uses ThreadLocalAccessor 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

      public static <T> reactor.core.publisher.Flux<T> withSentry(@NotNull @NotNull reactor.core.publisher.Flux<T> flux)
      Writes the current Sentry IScopes to the Context and uses ThreadLocalAccessor 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+)

    • withSentryForkedRoots

      public static <T> reactor.core.publisher.Flux<T> withSentryForkedRoots(@NotNull @NotNull reactor.core.publisher.Flux<T> flux)
      Writes a new Sentry IScopes forked from the main scopes to the Context and uses ThreadLocalAccessor 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+)

    • withSentryScopes

      public static <T> reactor.core.publisher.Flux<T> withSentryScopes(@NotNull @NotNull reactor.core.publisher.Flux<T> flux, @NotNull @NotNull IScopes scopes)
      Writes the given Sentry IScopes to the Context and uses ThreadLocalAccessor 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+)