Constructor Detail

Method Detail

• toFlux

   final static <T extends Any> Flux<T> toFlux(Publisher<T> $self)

  Extension to convert any Publisher of T to a Flux.

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

• toFlux

   final static <T extends Any> Flux<T> toFlux(Iterator<T> $self)

  Extension for transforming an Iterator to a Flux.

• toFlux

   final static <T extends Any> Flux<T> toFlux(Iterable<T> $self)

  Extension for transforming an Iterable to a Flux.

• toFlux

   final static <T extends Any> Flux<T> toFlux(Sequence<T> $self)

  Extension for transforming a Sequence to a Flux.

• toFlux

   final static <T extends Any> Flux<T> toFlux(Stream<T> $self)

  Extension for transforming a Stream to a Flux.

• toFlux

   final static Flux<Boolean> toFlux(BooleanArray $self)

  Extension for transforming a BooleanArray to a Flux.

• toFlux

   final static Flux<Byte> toFlux(ByteArray $self)

  Extension for transforming a ByteArray to a Flux.

• toFlux

   final static Flux<Short> toFlux(ShortArray $self)

  Extension for transforming a ShortArray to a Flux.

• toFlux

   final static Flux<Integer> toFlux(IntArray $self)

  Extension for transforming a IntArray to a Flux.

• toFlux

   final static Flux<Long> toFlux(LongArray $self)

  Extension for transforming a LongArray to a Flux.

• toFlux

   final static Flux<Float> toFlux(FloatArray $self)

  Extension for transforming a FloatArray to a Flux.

• toFlux

   final static Flux<Double> toFlux(DoubleArray $self)

  Extension for transforming a DoubleArray to a Flux.

• toFlux

   final static <T extends Any> Flux<T> toFlux(Array<out T> $self)

  Extension for transforming an Array to a Flux.

• toFlux

   final static <T extends Any> Flux<T> toFlux(Throwable $self)

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

• cast

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

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

• doOnError

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

  Extension for Flux.doOnError providing a KClass based variant.

• onErrorMap

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

  Extension for Flux.onErrorMap providing a KClass based variant.

• ofType

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

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

• onErrorResume

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

  Extension for Flux.onErrorResume providing a KClass based variant.

• onErrorReturn

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

  Extension for Flux.onErrorReturn providing a KClass based variant.

• split

   final static <T extends Any> Flux<T> split(Flux<out Iterable<T>> $self)

  Extension for flattening Flux of Iterable

• switchIfEmptyDeferred

   final static <T extends Any> Flux<T> switchIfEmptyDeferred(Flux<T> $self, Function0<Publisher<T>> s)

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

• collectMap

   final static <K extends Any, V extends Any> Mono<Map<K, V>> collectMap(Flux<Pair<K, V>> $self)

  Extension for Flux.collectMap to collect Kotlin Pairs into a Map