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

Struct averageInt32Operator

observable_operator.go:280–283  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

278}
279
280type averageInt32Operator struct {
281 sum int32
282 count int32
283}
284
285func (op *averageInt32Operator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
286 switch v := item.V.(type) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected