(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions)
| 201 | } |
| 202 | |
| 203 | func (op *averageInt8Operator) next(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) { |
| 204 | switch v := item.V.(type) { |
| 205 | default: |
| 206 | Error(IllegalInputError{error: fmt.Sprintf("expected type: int8, got: %t", item)}).SendContext(ctx, dst) |
| 207 | operatorOptions.stop() |
| 208 | case int8: |
| 209 | op.sum += v |
| 210 | op.count++ |
| 211 | } |
| 212 | } |
| 213 | |
| 214 | func (op *averageInt8Operator) err(ctx context.Context, item Item, dst chan<- Item, operatorOptions operatorOptions) { |
| 215 | defaultErrorFuncOperator(ctx, item, dst, operatorOptions) |
nothing calls this directly
no test coverage detected