Class FlowableInternalHelper

java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper

public final class FlowableInternalHelper extends Object
Helper utility class to support Flowable with inner classes.
  • Constructor Details

    • FlowableInternalHelper

      private FlowableInternalHelper()
      Utility class.
  • Method Details

    • simpleGenerator

      public static <T, S> BiFunction<S,Emitter<T>,S> simpleGenerator(Consumer<Emitter<T>> consumer)
    • simpleBiGenerator

      public static <T, S> BiFunction<S,Emitter<T>,S> simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)
    • itemDelay

      public static <T, U> Function<T,org.reactivestreams.Publisher<T>> itemDelay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay)
    • subscriberOnNext

      public static <T> Consumer<T> subscriberOnNext(org.reactivestreams.Subscriber<T> subscriber)
    • subscriberOnError

      public static <T> Consumer<Throwable> subscriberOnError(org.reactivestreams.Subscriber<T> subscriber)
    • subscriberOnComplete

      public static <T> Action subscriberOnComplete(org.reactivestreams.Subscriber<T> subscriber)
    • flatMapWithCombiner

      public static <T, U, R> Function<T,org.reactivestreams.Publisher<R>> flatMapWithCombiner(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> combiner)
    • flatMapIntoIterable

      public static <T, U> Function<T,org.reactivestreams.Publisher<U>> flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
    • replaySupplier

      public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent)
    • replaySupplier

      public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, int bufferSize, boolean eagerTruncate)
    • replaySupplier

      public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
    • replaySupplier

      public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)