Class FlowableCreate.NoOverflowBaseAsyncEmitter<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.NoOverflowBaseAsyncEmitter<T>
All Implemented Interfaces:
Emitter<T>, FlowableEmitter<T>, Serializable, org.reactivestreams.Subscription
Direct Known Subclasses:
FlowableCreate.DropAsyncEmitter, FlowableCreate.ErrorAsyncEmitter
Enclosing class:
FlowableCreate<T>

abstract static class FlowableCreate.NoOverflowBaseAsyncEmitter<T> extends FlowableCreate.BaseEmitter<T>
  • Field Details

  • Constructor Details

    • NoOverflowBaseAsyncEmitter

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

    • 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()