TimeInterval Operator

Overview

Convert an Observable that emits items into one that emits indications of the amount of time elapsed between those emissions.

Example

observable := rxgo.Interval(rxgo.WithDuration(time.Second)).TimeInterval()

Output:

1.002664s
1.004267s
1.00044s
...

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPublishStrategy