Class OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>

All Implemented Interfaces:
Serializable, AsyncEmitter<T>, Observer<T>, Producer, Subscription
Direct Known Subclasses:
OnSubscribeFromAsync.DropAsyncEmitter, OnSubscribeFromAsync.ErrorAsyncEmitter
Enclosing class:
OnSubscribeFromAsync<T>

abstract static class OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T> extends OnSubscribeFromAsync.BaseAsyncEmitter<T>
  • Field Details

  • Constructor Details

    • NoOverflowBaseAsyncEmitter

      public NoOverflowBaseAsyncEmitter(Subscriber<? super T> actual)
  • Method Details

    • onNext

      public final void onNext(T t)
      Description copied from interface: Observer
      Provides the Observer with a new item to observe.

      The Observable may call this method 0 or more times.

      The Observable will not call this method again after it calls either Observer.onCompleted() or Observer.onError(java.lang.Throwable).

      Parameters:
      t - the item emitted by the Observable
    • onOverflow

      abstract void onOverflow()