Method Distinct

observable_operator.go:744–751

Distinct suppresses duplicate items in the original Observable and returns a new Observable.

(apply Func, opts ...Option)

// Distinct suppresses duplicate items in the original Observable and returns
// a new Observable.
func (o *ObservableImpl) Distinct(apply Func, opts ...Option) Observable {
	return observable(o.parent, o, func() operator {
		return &distinctOperator{
			apply:  apply,
			keyset: make(map[interface{}]interface{}),
		}
	}, false, false, opts...)
}

type distinctOperator struct {
	apply  Func