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

Struct averageFloat64Operator

observable_operator.go:110–113  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

108}
109
110type averageFloat64Operator struct {
111 sum float64
112 count float64
113}
114
115func (op *averageFloat64Operator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
116 switch v := item.V.(type) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected