Method Repeat

observable_operator.go:1731–1745

Repeat returns an Observable that repeats the sequence of items emitted by the source Observable at most count times, at a particular frequency. Cannot run in parallel.

(count int64, frequency Duration, opts ...Option)

// at most count times, at a particular frequency.
// Cannot run in parallel.
func (o *ObservableImpl) Repeat(count int64, frequency Duration, opts ...Option) Observable {
	if count != Infinite {
		if count < 0 {
			return Thrown(IllegalInputError{error: "count must be positive"})
		}
	}

	return observable(o.parent, o, func() operator {
		return &repeatOperator{
			count:     count,
			frequency: frequency,
			seq:       make([]Item, 0),
		}
	}, true, false, opts...)
}

type repeatOperator struct {
	count     int64