Class FlowableCreate.NoOverflowBaseAsyncEmitter<T>

    • Constructor Detail

      • NoOverflowBaseAsyncEmitter

        NoOverflowBaseAsyncEmitter​(org.reactivestreams.Subscriber<? super T> downstream)
    • Method Detail

      • onNext

        public final void onNext​(T t)
        Description copied from interface: Emitter
        Signal a normal value.
        Parameters:
        t - the value to signal, not null
      • onOverflow

        abstract void onOverflow()