Method TimeInterval

observable_operator.go:2516–2549

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

(opts ...Option)

// TimeInterval converts an Observable that emits items into one that emits indications of the amount of time elapsed between those emissions.
func (o *ObservableImpl) TimeInterval(opts ...Option) Observable {
	f := func(ctx context.Context, next chan Item, option Option, opts ...Option) {
		defer close(next)
		observe := o.Observe(opts...)
		latest := time.Now().UTC()

		for {
			select {
			case <-ctx.Done():
				return
			case item, ok := <-observe:
				if !ok {
					return
				}
				if item.Error() {
					if !item.SendContext(ctx, next) {
						return
					}
					if option.getErrorStrategy() == StopOnError {
						return
					}
				} else {
					now := time.Now().UTC()
					if !Of(now.Sub(latest)).SendContext(ctx, next) {
						return
					}
					latest = now
				}
			}
		}
	}

	return customObservableOperator(o.parent, f, opts...)
}

// Timestamp attaches a timestamp to each item emitted by an Observable indicating when it was emitted.
func (o *ObservableImpl) Timestamp(opts ...Option) Observable {