RxJava 過濾操作符 sample

阿新 • • 發佈：2019-02-05

sample操作符是定期掃描源Observable產生的結果，在指定的間隔週期內進行取樣

例子1：每2s掃描一次

 Observable.interval(1, TimeUnit.SECONDS).sample(2, TimeUnit.SECONDS).subscribe(new Observer<Long>() {
            @Override
            public void onCompleted() {
                LogUtils.d("-------->onCompleted()");
            }

            @Override
            public void onError(Throwable e) {
                LogUtils.d("-------->onError()" + e);
            }

            @Override
            public void onNext(Long aLong) {
                LogUtils.d("-------->onNext()" + aLong);
            }
        });

結果:

03-02 09:36:08.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()0
03-02 09:36:10.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()2
03-02 09:36:12.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()4
03-02 09:36:14.722 8623-8768/com.rxandroid.test1 D/----->: -------->onNext()6

.....

注意這裡會預設開啟一個新執行緒，我們也可以指定執行緒

Observable.interval(1, TimeUnit.SECONDS).sample(2, TimeUnit.SECONDS, Schedulers.newThread()).subscribe(new Observer<Long>() {
            @Override
            public void onCompleted() {
                LogUtils.d("-------->onCompleted()");
            }

            @Override
            public void onError(Throwable e) {
                LogUtils.d("-------->onError()" + e);
            }

            @Override
            public void onNext(Long aLong) {
                LogUtils.d("-------->onNext()" + aLong + "   thread:" + Thread.currentThread().getName());
            }
        });

結果:

03-02 09:43:25.582 15427-15698/com.rxandroid.test1 D/----->: -------->onNext()0 thread:RxNewThreadScheduler-2

....

RxJava 過濾操作符 sample

sample操作符是定期掃描源Observable產生的結果，在指定的間隔週期內進行取樣例子1：每2s掃描一次 Observable.interval(1, TimeUnit.SECONDS).sample(2, TimeUnit.SECONDS).subscribe(

RxJava過濾操作符filter、elementAt、distinct、skip、take、ignoreElements、throttleFirst， buffer

原 https://blog.csdn.net/qq_36523667/article/details/78761470 Android函式響應式程式設計——必學的RxJava過濾操作符filter、elementAt、distinct、skip、take、ignoreElements、throt

RxJava 過濾操作符（Filtering Observables Operators）

RxJava系列教程： “過濾操作”，顧名思義，就是過濾掉Observable發射的一些資料，不讓他發射出去，也就是忽略丟棄掉，至於需要過濾那些資料，就需要按照不同的規則，所以RxJava有一些列關於過濾的操作符，接下來看看RxJava中的過濾操作符。

RxJava過濾操作符

概述過濾操作符用於過濾和選擇Observable發射的資料序列，讓Observable只返回滿足我們條件的資料。 Debounce Debounce會過濾掉髮射速率過快的資料項，相當於限流，但是需要注意的是debounce過濾掉的資料會被丟棄掉。

RxJava系列4(過濾操作符)

RxJava 2.x 之過濾操作符

最近幾天想把rxjava2的操作符都整理一下，看到網上的很多文章都總結的很好，但是時間久了依然會忘記。過濾操作符 filter操作符 take操作符 takeLast操作符 firstElement/lastElement操作符 first/la

Android RxJava操作符的學習---過濾操作符----聯想搜尋優化

1. 需求場景 2. 功能說明 3. 具體實現佈局檔案：activity_filter.xml <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="ht

Android RxJava操作符的學習---過濾操作符----功能防抖

1. 需求場景 2. 功能說明 3. 具體實現 // 註冊控制元件 Button button; button = (Button)findViewById(R.id.button); /*

Android RxJava操作符的學習---過濾操作符

3.5 過濾操作符作用過濾 / 篩選被觀察者（Observable）傳送的事件 & 觀察者（Observer）接收的事件應用場景根據指定條件過濾事件根據指定事件數量過濾事件根據指定時間過濾事件

RxJava使用詳解--過濾操作符

RxJava使用詳解系列文章詳細的例子可以檢視文章末尾的原始碼這篇文章主要講RxJava中常見的過濾操作符 1.debounce操作符源Observable每發射一個數據項，如果在debounce規定的間隔時間內Observable沒有發射新的資料項，

RxJava操作符（五） ----過濾操作符

RxJava各型別操作符詳解如下：過濾操作符：用於將Observable傳送的資料進行過濾和選擇。讓Observable返回我們所需要的資料。過濾操作符有buffer()，filter()，skip()，take()，skipLast(

Rxjava 的過濾操作符

public class RxFilterActivity extends AppCompatActivity { private final static String TAG = RxFilterActivity.class.getSimpleName(); @

RxJS之過濾操作符 ( Angular環境 )

idt from 數量 microsoft val ole import port 操作符一 take操作符只發出源 Observable 最初發出的的N個值 (N = count)。如果源發出值的數量小於 count 的話，那麽它的所有值都將發出。然後它便完成，無論

RxJava window操作符<三零>

原文：https://github.com/Froussios/Intro-To-RxJava/blob/master/Part%204%20-%20Concurrency/3.%20Sequences%20of%20coincidence.md Sequences of coincidence Rx試

RxJava2 Flowable distinct(過濾操作符)

distinct(Function<? super T,K> keySelector) Returns a Flowable that emits all items emitted by the source Publisher that are distinct according to

RxJava2 Flowable first 、last (過濾操作符)

測試程式碼 @Test public void first() { System.out.println("######first#####"); System.out.println("測試1：源Publisher不為空"); Flowable.ju

RxJava2知識回顧之RxJava基本操作符

Map 操作符的作用是對上游傳送的每一個事件應用一個函式，使得每個事件按照函式的邏輯進行變換，通過Map就可以把上游傳送的每一個事件，轉換成Object或者集合. /** * map關鍵詞主要是將傳送事件通過Map轉換成另一種下游所需要的目標型別 *

RxJava 常用操作符大全（一）

create create操作符是所有建立型操作符的“根”，也就是說其他建立型操作符最後都是通過create操作符來建立Observable的呼叫例子如下： Observable.create(new Observable.OnSubscribe&l

Android RxJava使用介紹（二） RxJava的操作符

上一篇文章我們通過一個簡單的例子來給大家展示了RxJava的基本用法，相信大家已經對RxJava有了大概的瞭解，由於上篇文章對RxJava的使用介紹都是點到為止，並沒有進行深入展開，也許你對RxJava有種名不副實的感覺。OK，下面我們就進入正題，一步步的揭開R

[RxJava學習]操作符Do的使用

Observable中Do系列的函式，是通過註冊回撥的方式，來偵聽鏈式操作過程的各個動作節點。函式名函式用途函式原型 doOnNext 在每次發射元素之前（呼叫subScriber.onNext()）做一些額外的事情,不改變發射元素的值，只是插入了一個偵聽 Obs

RxJava 過濾操作符 sample

相關推薦