RxJava簡單介紹

建立操作符型別：負責建立obervable物件

變換操作符：用來對observable發射的資料執行變化操作

過濾操作符：用於過濾和選擇observable發射的資料序列

結合操作符：在多個observable的組合時候使用

輔助操作符：用於observable的輔助操作符

observable observable = observable.create(new observable.onsubscribe

()});
observable.subscribeon(schedulers.computation())
.observeon(androidschedulers.mainthread())
.subscribe(subscriber);

subscribersubscriber = new subscriber()

@override
public
void
onerror(throwable e)
@override
public
void
onnext(string s)
}

Rxjava2的簡單實用

第一種方式實現觀察者和被觀察者的建立和建立聯絡 1 建立被觀察者 建立被觀察者 傳送資料 observable observable observable.create new observableonsubscribe 2 建立觀察者 建立觀察者 接受資料 io.reactivex.observe...

RxJava筆記 RxJava操作符

用來建立observable。public static observablecreate onsubscribef 把其他型別的物件和資料型別轉化成observable。observable.just 123 把其他型別的物件和資料型別轉化成observable。與just區別在與引數返回值不同 ...

RxJava 變換操作

buffer buffer操作符，將原有observable發射的資料快取起來，比如buffer 2 就每2個資料放進乙個集合，然後發射這個集合出去。buffer方法有很多過載的方法。flatmap 該操作符，使用乙個指定的函式對原始observable發射的每一項資料執行變換操作 lift 這個函...