RxJava2
2019-03-19 19:04:06 0 举报
登录查看完整内容
RxJava2简单关系图，慢慢补充
作者其他创作
大纲/内容
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
收藏
职业：软件工程师
0 条评论
回复 删除
下一页
