Rxjava2的簡單實用

第一種方式實現觀察者和被觀察者的建立和建立聯絡

1、建立被觀察者

//        建立被觀察者(傳送資料)

observable observable = observable.create(new observableonsubscribe() 
});

//        建立觀察者(接受資料)

io.reactivex.observerobserver = new io.reactivex.observer() 
@override
public void onnext(string value) 
@override
public void onerror(throwable e) 
@override
public void oncomplete() 
};

observable.subscribe(observer);

observableobservable.subscribe(new consumer() 

}, new consumer() 
}, new action() 
});建立觀察者和實現觀察者、被觀察者之間的關係步驟同第一種

//        建立被觀察者(傳送資料)

observableobservable.subscribe(new consumer() 
}, new consumer() 
}, new action() 
});建立觀察者和實現觀察者、被觀察者之間的關係步驟同第一種

observable observable = observable.just("***","泡吧","ddd");

建立觀察者和實現觀察者、被觀察者之間的關係步驟同第一種

observable observable = observable.fromarray("***","泡吧","ddd");

建立觀察者和實現觀察者、被觀察者之間的關係步驟同第一種

observable observable = observable.fromcallable(new callable() 

});建立觀察者和實現觀察者、被觀察者之間的關係步驟同第一種
RxJava2原始碼解析
原始碼總結 observabel 通過create方法。將observableonsubscribe物件傳遞給自己。通過subscribe方法。建立 observableemitter發射器物件。發射器裡又封裝了observer。發射器又作為引數傳遞 給observableonsubscribe物件...
RxJava2實現執行緒切換
被觀察者 observable 觀察者 observer 訂閱 subscribe 1 建立被觀察者 observable observable observable.create new observableonsubscribe 2 建立觀察者 observer observer new obs...
RxJava2簡單使用三（執行緒排程）
之前我也用到過執行緒排程，但是沒有仔細講這個問題，我這裡作為新手還是解釋一下 執行緒排程一 基本配置 subscribeon schedulers.newthread 將被觀察者設定在乙個新的執行緒來執行 observeon androidschedulers.mainthread 將觀察者設定在主...