MCPcopy Create free account
hub / github.com/ReactiveX/RxGo / containsOperator

Struct containsOperator

observable_operator.go:612–615  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

610}
611
612type containsOperator struct {
613 equal Predicate
614 contains bool
615}
616
617func (op *containsOperator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
618 if op.equal(item.V) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected