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

Struct averageInt64Operator

observable_operator.go:321–324  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

319}
320
321type averageInt64Operator struct {
322 sum int64
323 count int64
324}
325
326func (op *averageInt64Operator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
327 switch v := item.V.(type) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected