1、RxJava是一種基于觀察者模式的響應式編程框架，其中的主要角色有：Observable 是RxJava描述的事件流，在鍊式調用中非常清晰，事件從創建到加工處理再到被訂閱者接收到，就是一個接一個的Observable形成的一個事件流。
2、每一步方法的調用，都會返回一個新的Observable給下一步，這個是RxJava源碼的基礎。同樣是鍊式調用，但它與我們常見的Builder模式不太一樣，每個操作符，每次線程切換，每步都會新建一個Observable而非直接加工上一步的Observable返回給下一步。
3、ObservableOnSubscribe 是這個事件流的源頭，下面我們稱之為事件源，一般由我們自己創建并傳入。我們創建時，需要重寫其subscribe()方法，為了和Observable中的subscribe()方法區别，我們将在下面貼出的代碼中将其改名為call()。
4、我們在調用鍊中有時會用到各種操作符進行一些變換，事實上每個操作符都會重寫這麼一個call()方法，相對于我們創建事件源時在這裡寫入的源業務代碼，這些操作符在這裡要做的事是由RxJava欽定的，一般是連接事件流的上下遊。在這裡我們将準備好被訂閱的數據，并調用subscribe()參數中ObservableEmitter的onNext()，onCompleted()或onError()通知訂閱者數據準備情況。
5、Observer 是整個事件流的訂閱者，也就是說，它将會訂閱前面事件創建，加工以後的最終結果。它也是由我們創建的，我們将要重寫它的onNext()，onCompleted()，onError()和onSubscribe()，在接下來的分析中我們将簡化一些，隻關注onNext()。我們創建出了Observer以後，将會使用經過上面所有步驟的最後一步生成的Observable，調用它的subscribe()，與事件源産生聯系。
更多精彩资讯请关注tft每日頭條，我们将持续为您更新最新资讯!
zpostcode 
Recruit 
weather 
mreligion 
Yellowpages 
sport 
constellation 
shopping 
name 
game 
directory 
literature 
Word 
tour 
furnish 
Lottery 
tftnews 
lyrics 
News 
digital 
car 
dir 
Edu 
Finance 
