RxJava Debounce onNext（）

Question

SwitchCompatのクリック/スワイプをデバウンスしようとしていますが、成功しません。 onNextはdebounce（）を経由していませんが、以下のコードはうまく見えます：ユーザーがスイッチをスパムすると、onNextはデバッグのために省略されず、クリックごとに呼び出されます。

これはRxJavaのバグでしょうか？

timer = Observable.create { subscriber: Subscriber<in Void>? -> 
     super.setOnCheckedChangeListener { buttonView, isChecked -> 
      subscriber?.onNext(null) 
     } 
    } 
    timer.debounce(3,TimeUnit.SECONDS) 

Answer 1

これが実際のコードの場合は、問題はdebounceにはまったく関係しないと思います。ほとんどのRx演算子と同様に、debounceは新しいObservableを返します。timerが指しているものを変更しません。

debounceによって返された参照を保存していないため、基本的に何も起こりません。

試してみてください。timer = timer.debounce(3, TimeUnit.SECONDS)

Answer 2

あなたがジェイク・ウォートンからRxBinding libraryを使用する必要があります。それはアンドロイドウィジェットをRxにラップします。あなたはKotlin & RxBinding Kotlin Versionを使用している場合

RxCompoundButton.checkedChanges(switchCompat) 
    .debounce(3, TimeUnit.SECONDS) 
    .subscribe(); 

Answer 3

：あなたのためにあなたは、このように使用することができますRxCompoundButtonは、そこにあります。あなたは、あなたのプロジェクトにRxBindingを使用することを許可されていない場合は、カスタムCompoundButton

import com.jakewharton.rxbinding.widget.checkedChanges 

class CustomCompoundButton: CompoundButton { 
    constructor(context: Context): super(context, null) 

    constructor(context: Context, attrs: AttributeSet?): super(context, attrs, 0) 

    constructor(context: Context, attrs: AttributeSet, defStyleAttr: Int): super(context, attrs, defStyleAttr, 0) 

    fun throttledCheckedChanges() { 
     return this.checkedChanges().debounce(3, TimeUnit.SECONDS) 
    } 
    // OR 
    val throttledCheckedChanges by lazy { 
     this.checkedChanges().debounce(3, TimeUnit.SECONDS) 
    } 

} 

// Use it in your activity/ fragment 
customCompoundButton.throttledCheckedChanges().subscribe { /* do sth */ } 
// OR 
customCompoundButton.throttledCheckedChanges.subscribe { /* do sth */ } 

で表現することができます。 Rxラッパーの作成については、CompoundButtonCheckedChangeObservable.javaをご覧ください。