});
執行結果如下：
執行結果如下：01
});
執行結果如下：
// 下面通過比較defer操作符和just操作符的執行結果作比較：
i=10;
observable justobservable = observable.just(i);
i=12;
observable deferobservable = observable.defer(new func0>()
});i=15;
justobservable.subscribe(new subscriber()
@override
public
void
onerror(throwable e)
@override
public
void
onnext(object o)
});deferobservable.subscribe(new subscriber()
@override
public
void
onerror(throwable e)
@override
public
void
onnext(object o)
});}
其中i是類的成員變數，執行結果如下：
just
result
:10defer
result
:15
可以看到，just操作符是在建立observable就進行了賦值操作，而defer是在訂閱者訂閱時才建立observable，此時才進行真正的賦值操作
//每隔兩秒產生乙個數字
observable.timer(2, 2, timeunit.seconds).subscribe(new subscriber()
@override
public
void
onerror(throwable e)
@override
public
void
onnext(long along)
});
執行結果如下：
呼叫例子就不列出了，基本跟上面timer的呼叫例子一樣。
//產生從3開始，個數為10個的連續數字
observable.range(3,10).subscribe(new subscriber()
@override
public
void
onerror(throwable e)
@override
public
void
onnext(integer i)
});
執行結果如下：
repeat呼叫例子如下：
//連續產生兩組(3,4,5)的數字
observable.range(3,3).repeat(2).subscribe(new subscriber()
@override
public
void
onerror(throwable e)
@override
public
void
onnext(integer i)
});
執行結果如下：
next:3
next:4
next:5
next:3
next:4
next:5
sequence complete.
//repeatwhen呼叫例子如下：
observable.just(1,2,3).repeatwhen(new func1, observable>>()
}).flatmap(new func1>()
});}
}).subscribe(new subscriber()
@override
public
void
onerror(throwable e)
@override
public
void
onnext(integer value)
});
執行結果如下：
next:1
next:2
next:3
repeat the 1 count
next:1
next:2
next:3
repeat the 2 count
next:1
next:2
next:3
repeat the 3 count
next:1
next:2
next:3
sequence complete.
RxJava筆記 RxJava操作符
用來建立observable。public static observablecreate onsubscribef 把其他型別的物件和資料型別轉化成observable。observable.just 123 把其他型別的物件和資料型別轉化成observable。與just區別在與引數返回值不同 ...
RxJava操作符學習
操作符學習推薦閱讀 官方英文 翻譯中文 先來看乙個簡單的例子 被觀察者 observable.onsubscribeintegeronsubscribe new observable.onsubscribe 觀察者 subscriberintegersubscriber new subscriber...
RxJava常用操作符
用於建立observable 被觀察者 的操作符 用於對observable發出的資料進行變換的操作符 用於從observable發射的資料中選擇性的過濾一些資料的操作符 用於將多個observable組合成乙個單一的observable的操作符 有助於從observable的錯誤通知中恢復的操作符...