Interface Emitter<T>

Type Parameters:
T - the value type emitted
All Known Subinterfaces:
FlowableEmitter<T>, ObservableEmitter<T>
public interface Emitter<@NonNull T>
Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).

Note that the onNext(T), onError(Throwable) and onComplete() methods provided to the function via the Emitter instance should be called synchronously, never concurrently. Calling them from multiple threads is not supported and leads to an undefined behavior.

  • Method Details

    • onNext

      void onNext(@NonNull @NonNull T value)
      Signal a normal value.
      Parameters:
      value - the value to signal, not null

    • onError

      void onError(@NonNull @NonNull Throwable error)
      Signal a Throwable exception.
      Parameters:
      error - the Throwable to signal, not null

    • onComplete

      void onComplete()
      Signal a completion.