Class FlowableBufferBoundary<T,​U extends java.util.Collection<? super T>,​Open,​Close>

    • Field Detail

      • bufferSupplier

        final Supplier<U extends java.util.Collection<? super T>> bufferSupplier
      • bufferOpen

        final org.reactivestreams.Publisher<? extends Open> bufferOpen
      • bufferClose

        final Function<? super Open,​? extends org.reactivestreams.Publisher<? extends Close>> bufferClose
    • Constructor Detail

      • FlowableBufferBoundary

        public FlowableBufferBoundary​(Flowable<T> source,
                                      org.reactivestreams.Publisher<? extends Open> bufferOpen,
                                      Function<? super Open,​? extends org.reactivestreams.Publisher<? extends Close>> bufferClose,
                                      Supplier<U> bufferSupplier)
    • Method Detail

      • subscribeActual

        protected void subscribeActual​(org.reactivestreams.Subscriber<? super U> s)
        Description copied from class: Flowable
        Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Subscribers.

        There is no need to call any of the plugin hooks on the current Flowable instance or the Subscriber; all hooks and basic safeguards have been applied by Flowable.subscribe(Subscriber) before this method gets called.

        Specified by:
        subscribeActual in class Flowable<U extends java.util.Collection<? super T>>
        Parameters:
        s - the incoming Subscriber, never null