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

Struct allOperator

observable_operator.go:25–28  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

23}
24
25type allOperator struct {
26 predicate Predicate
27 all bool
28}
29
30func (op *allOperator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
31 if !op.predicate(item.V) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected