Debounce Operator

February 25, 2020 ยท View on GitHub

Overview

Only emit an item from an Observable if a particular timespan has passed without it emitting another item.

Example

observable.Debounce(rxgo.WithDuration(250 * time.Millisecond))

Output: each item emitted by the Observable if not item has been emitted after 250 milliseconds.

Options

  • WithBufferedChannel

  • WithContext

  • WithObservationStrategy

  • WithErrorStrategy

  • WithPool

  • WithCPUPool

  • WithPublishStrategy

Contents

  1. 1Overview
  2. 2Example
  3. 3Options