Class FlowableInternalHelper


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

      • FlowableInternalHelper

        private FlowableInternalHelper()
        Utility class.
    • Method Detail

      • 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<java.lang.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 java.lang.Iterable<? extends U>> mapper)
      • replaySupplier

        public static <T> Supplier<ConnectableFlowable<T>> replaySupplier​(Flowable<T> parent,
                                                                          int bufferSize,
                                                                          long time,
                                                                          java.util.concurrent.TimeUnit unit,
                                                                          Scheduler scheduler,
                                                                          boolean eagerTruncate)