debounce.md

Debounce Operator

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