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

Struct averageInt8Operator

observable_operator.go:198–201  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

196}
197
198type averageInt8Operator struct {
199 sum int8
200 count int8
201}
202
203func (op *averageInt8Operator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) {
204 switch v := item.V.(type) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected