Observer
+ onSubscribe(Disposable)+ onNext(T)+ onError(Throwable)+ onComplete()
SerializedEmitter
+ emitter:ObservableEmitter+ error:AtomicThrowable- queue:SpscLinkedArrayQueue
- drain()- drainLoop()
ObservableEmitter
+ setDisposable(Disposable)+ setCancellable(Cancellable)+ isDisposed(): Boolean+ serialize(): ObservableEmitter+ tryOnError(Throwable): Boolean
ObservableCreate
- source:ObservableOnSubscribe
+ subscribeActual(Observer)
Observable
+ create(ObservableOnSubscribe)
Emitter
+ onNext(T)+ onError(Throwable)+ onComplete()
ObservableSource
+ subscribe(Observer)
CreateEmitter
+ observer:Observer
+ serialize(): SerializedEmitter
ObservableOnSubscribe
+ subscribe(ObservableEmitter)
Disposable
+ dispose()+ isDisposed(): Boolean
