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

Struct averageInt16Operator

observable_operator.go:239–242  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

237}
238
239type averageInt16Operator struct {
240 sum int16
241 count int16
242}
243
244func (op *averageInt16Operator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
245 switch v := item.V.(type) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected