Repeat Operator

February 25, 2020 ยท View on GitHub

Overview

Create an Observable that emits a particular item multiple times at a particular frequency.

Example

observable := rxgo.Just(1, 2, 3)().
	Repeat(3, rxgo.WithDuration(time.Second))

Output:

// Immediately
1
2
3
// After 1 second
1
2
3
// After 2 seconds
1
2
3
...

Options

  • WithBufferedChannel

  • WithContext

  • WithObservationStrategy

  • WithErrorStrategy

  • WithPublishStrategy

Contents

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