repeat

創建可多次發出特定項目的Observable??

1 repeat 設置重復的次數?

     Observable.just(5).repeat().subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.d("-----repeat",integer.toString());}});

重復5次

2 repeatWhen 設置重復的次數,不過添加了一個條件 

  Observable.just(1).repeatWhen(new Function<Observable<Object>, ObservableSource<?>>() {@Overridepublic ObservableSource<?> apply(Observable<Object> objectObservable) throws Throwable {return objectObservable.delay(5,TimeUnit.SECONDS);}}).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.d("-----repeat",integer.toString());}});

5秒重復輸出1此,

3?repeatUntil 設置重復,知道條件判斷為止

   Integer[] numbers = new Integer[]{0, 1, 2, 3, 4};Observable.fromArray(numbers).repeatUntil(new BooleanSupplier() {@Overridepublic boolean getAsBoolean() throws Exception {boolean b;int rand = (int) (Math.random() * 10);//如果隨機產生的整數大于5，停止重復。if (rand > 5) {b = true;} else {b = false;}return b;}}).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.d("-----repeat",integer.toString());}});

隨即說大于5 停止..

總結

以上是生活随笔為你收集整理的RxJava repeat,repeatWhen,repeatUntil 的区别的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。