Emitter

Type Parameters:

T - the value type emitted

All Known Subinterfaces:

FlowableEmitter<T>, ObservableEmitter<T>

All Known Implementing Classes:

FlowableCreate.BaseEmitter, FlowableCreate.BufferAsyncEmitter, FlowableCreate.DropAsyncEmitter, FlowableCreate.ErrorAsyncEmitter, FlowableCreate.LatestAsyncEmitter, FlowableCreate.MissingEmitter, FlowableCreate.NoOverflowBaseAsyncEmitter, FlowableCreate.SerializedEmitter, FlowableGenerate.GeneratorSubscription, ObservableCreate.CreateEmitter, ObservableCreate.SerializedEmitter, ObservableGenerate.GeneratorDisposable
```
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(java.lang.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 Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Signal a completion.
`void`	`onError(@NonNull java.lang.Throwable error)`	Signal a `Throwable` exception.
`void`	`onNext(@NonNull T value)`	Signal a normal value.

- Method Detail
  - onNext
```
void onNext(@NonNull
            @NonNull T value)
```
    Signal a normal value.
    
    Parameters:
    
    value - the value to signal, not null
  - onError
```
void onError(@NonNull
             @NonNull java.lang.Throwable error)
```
    Signal a Throwable exception.
    
    Parameters:
    
    error - the Throwable to signal, not null
  - onComplete
```
void onComplete()
```
    Signal a completion.