Class FlowableCreate.MissingEmitter<T>

All Implemented Interfaces:
Emitter<T>, FlowableEmitter<T>, Serializable, org.reactivestreams.Subscription
Enclosing class:
FlowableCreate<T>

static final class FlowableCreate.MissingEmitter<T> extends FlowableCreate.BaseEmitter<T>
  • Field Details

  • Constructor Details

    • MissingEmitter

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

    • onNext

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