Method Filter

observable_operator.go:995–999

Filter emits only those items from an Observable that pass a predicate test.

(apply Predicate, opts ...Option)

// Filter emits only those items from an Observable that pass a predicate test.
func (o *ObservableImpl) Filter(apply Predicate, opts ...Option) Observable {
	return observable(o.parent, o, func() operator {
		return &filterOperator{apply: apply}
	}, false, true, opts...)
}

type filterOperator struct {
	apply Predicate