Method DistinctUntilChanged

observable_operator.go:793–799

DistinctUntilChanged suppresses consecutive duplicate items in the original Observable. Cannot be run in parallel.

(apply Func, opts ...Option)

// DistinctUntilChanged suppresses consecutive duplicate items in the original Observable.
// Cannot be run in parallel.
func (o *ObservableImpl) DistinctUntilChanged(apply Func, opts ...Option) Observable {
	return observable(o.parent, o, func() operator {
		return &distinctUntilChangedOperator{
			apply: apply,
		}
	}, true, false, opts...)
}

type distinctUntilChangedOperator struct {
	apply   Func