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

Struct countOperator

observable_operator.go:650–652  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

648}
649
650type countOperator struct {
651 count int64
652}
653
654func (op *countOperator) next(_ context.Context, _ Item, _ chan<- Item, _ operatorOptions) {
655 op.count++

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected