| 155 | } |
| 156 | |
| 157 | type averageIntOperator struct { |
| 158 | sum int |
| 159 | count int |
| 160 | } |
| 161 | |
| 162 | func (op *averageIntOperator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) { |
| 163 | switch v := item.V.(type) { |
nothing calls this directly
no outgoing calls
no test coverage detected