Debouncing操做符 RxJava 學習筆記<二十>

Debouncing  

   在此運算符中，每次接收到值時都會啓動時間窗口。窗口到期後，將發出該值。可是，若是在窗口到期以前收到另外一個值，則拒絕前一個值，窗口將從新開始下一個值。

    證實這一點有點複雜，由於一個可觀察的區間要麼接受它的全部值，要麼只接受它的最後一個值（若是可觀察的是無限的，則永遠不會）。所以，咱們將構建一個更復雜的可觀察對象。

    輸出：

    正如咱們在這裏看到的，咱們的可觀測量將快速連續發出4個值，而後是更大間隔中的3個值，最後是快速連續的3個值。掃描僅用於將值轉換爲天然序列，而不是3次重複1,2,3。前兩個發射同時發生的緣由是該掃描一塊兒發射初始值和第一個值。

    如今咱們瞭解了咱們的源可觀察性，讓咱們去 debounce 它：

    日誌輸出：

    咱們以150毫秒的窗口進行了 debounce。咱們可觀察到的爆發速度比那個（100毫秒）要快，因此只有每一個爆發中的最後一個值才能經過。在咱們可觀察的較慢部分期間，全部值都被接受，由於150ms窗口在下一個值到達以前到期。

    有一個throttleWithTimeout運算符，它與咱們剛剛看到的debounce運算符具備相同的行爲。一個其實是另外一個的別名，即便文檔中沒有正式宣佈這兩個。

    您還能夠根據每件商品進行去抖動。在這種狀況下，您提供了一個函數，該函數計算每一個項目後窗口應該有多長。您發出信號代表窗口正在爲每一個項目使用新的可觀察對象。當observable終止時，窗口到期。

    在下一個示例中，每一個值i的窗口大小爲i * 50ms。

    日誌輸出：

     讓咱們將每一個項目映射到其窗口的長度以及下一個項目實際到達的時間

    咱們如今能夠看到爲何值如此。

    該運算符對於經歷不肯定時期的可觀察量是有用的，其中值常常從一個非肯定狀態變化到另外一個非肯定狀態。例如，假設您正在監視文本字段的內容，而且您但願根據用戶正在寫入的內容提供建議。您能夠在每次按鍵時從新計算您的建議，但這樣會太嘈雜並且成本過高。相反，若是您去除了對文本字段的更改，則只有在用戶暫停或完成輸入時纔會提供建議。

原文：https://github.com/Froussios/Intro-To-RxJava/blob/master/Part%203%20-%20Taming%20the%20sequence/5.%20Time-shifted%20sequences.md

下節繼續！

有什麼討論的內容，能夠加我公衆號：