Package reactor.kotlin.core.publisher

Class MonoExtensionsKt

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description

    • Field Summary

      Fields 
      Modifier and Type Field Description

    • Constructor Summary

      Constructors 
      Constructor Description

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description

    • Method Summary

      Modifier and Type Method Description
      final static <T extends Any> Mono<T> cast(Mono<?> $self) Extension for Mono.cast providing a cast<Foo>() variant.
      final static <T extends Any, E extends Throwable> Mono<T> doOnError(Mono<T> $self, KClass<E> exceptionType, Function1<E, Unit> onError) Extension for Mono.doOnError providing a KClass based variant.
      final static <T extends Any, E extends Throwable> Mono<T> onErrorMap(Mono<T> $self, KClass<E> exceptionType, Function1<E, Throwable> mapper) Extension for Mono.onErrorMap providing a KClass based variant.
      final static <E extends Throwable, T extends Any> Mono<T> onErrorMap(Mono<T> $self, KClass<E> type, Function1<E, Boolean> predicate, Function1<E, Throwable> mapper) Extension for Mono.onErrorMap providing a KClass based variant and predicate.
      final static <T extends Any> Mono<T> ofType(Mono<?> $self) Extension for Mono.ofType providing a ofType<Foo>() variant.
      final static <T extends Any, E extends Throwable> Mono<T> onErrorResume(Mono<T> $self, KClass<E> exceptionType, Function1<E, Mono<T>> fallback) Extension for Mono.onErrorResume providing a KClass based variant.
      final static <T extends Any, E extends Throwable> Mono<T> onErrorReturn(Mono<T> $self, KClass<E> exceptionType, T value) Extension for Mono.onErrorReturn providing a KClass based variant.
      final static <T extends Any> Mono<T> toMono(Publisher<T> $self) Extension to convert any Publisher of T to a Mono that only emits its first element.
      final static <T extends Any> Mono<T> toMono(Function0<T> $self) Extension to convert any Supplier of T to a Mono that emits supplied element.
      final static <T extends Any> Mono<T> toMono(T $self) Extension for transforming a nullable object to a Mono.
      final static <T extends Any> Mono<T> toMono(CompletableFuture<out T> $self) Extension for transforming an CompletableFuture to a Mono.
      final static <T extends Any> Mono<T> toMono(Callable<T> $self) Extension for transforming an Callable to a Mono.
      final static <T extends Any> Mono<T> toMono(Throwable $self) Extension for transforming an exception to a Mono that completes with the specified error.
      final static <T extends Any> Mono<T> switchIfEmpty(Mono<T> $self, Function0<Mono<T>> s) Extension for Mono.switchIfEmpty accepting a function providing a Mono.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

    • Method Detail

      • cast

         final static <T extends Any> Mono<T> cast(Mono<?> $self)

        Extension for Mono.cast providing a cast<Foo>() variant.

        Since:

        3.1

      • doOnError

         final static <T extends Any, E extends Throwable> Mono<T> doOnError(Mono<T> $self, KClass<E> exceptionType, Function1<E, Unit> onError)

        Extension for Mono.doOnError providing a KClass based variant.

        Since:

        3.1

      • onErrorMap

         final static <T extends Any, E extends Throwable> Mono<T> onErrorMap(Mono<T> $self, KClass<E> exceptionType, Function1<E, Throwable> mapper)

        Extension for Mono.onErrorMap providing a KClass based variant.

        Since:

        3.1

      • onErrorMap

         final static <E extends Throwable, T extends Any> Mono<T> onErrorMap(Mono<T> $self, KClass<E> type, Function1<E, Boolean> predicate, Function1<E, Throwable> mapper)

        Extension for Mono.onErrorMap providing a KClass based variant and predicate.

        Since:

        3.3.1

      • ofType

         final static <T extends Any> Mono<T> ofType(Mono<?> $self)

        Extension for Mono.ofType providing a ofType<Foo>() variant.

        Since:

        3.1

      • onErrorResume

         final static <T extends Any, E extends Throwable> Mono<T> onErrorResume(Mono<T> $self, KClass<E> exceptionType, Function1<E, Mono<T>> fallback)

        Extension for Mono.onErrorResume providing a KClass based variant.

        Since:

        3.1

      • onErrorReturn

         final static <T extends Any, E extends Throwable> Mono<T> onErrorReturn(Mono<T> $self, KClass<E> exceptionType, T value)

        Extension for Mono.onErrorReturn providing a KClass based variant.

        Since:

        3.1

      • toMono

         final static <T extends Any> Mono<T> toMono(Publisher<T> $self)

        Extension to convert any Publisher of T to a Mono that only emits its first element.

        Note this extension doesn't make much sense on a Mono but it won't be converted so it doesn't hurt.

        Since:

        3.1.1

      • toMono

         final static <T extends Any> Mono<T> toMono(Function0<T> $self)

        Extension to convert any Supplier of T to a Mono that emits supplied element.

      • toMono

         final static <T extends Any> Mono<T> toMono(T $self)

        Extension for transforming a nullable object to a Mono.

        Since:

        3.1

      • toMono

         final static <T extends Any> Mono<T> toMono(Callable<T> $self)

        Extension for transforming an Callable to a Mono.

        Since:

        3.1

      • toMono

         final static <T extends Any> Mono<T> toMono(Throwable $self)

        Extension for transforming an exception to a Mono that completes with the specified error.

        Since:

        3.1

      • switchIfEmpty

         final static <T extends Any> Mono<T> switchIfEmpty(Mono<T> $self, Function0<Mono<T>> s)

        Extension for Mono.switchIfEmpty accepting a function providing a Mono. This allows having a deferred execution with the switchIfEmpty operator

        Since:

        3.2