| 411 | } |
| 412 | |
| 413 | type bufferWithCountOperator struct { |
| 414 | count int |
| 415 | iCount int |
| 416 | buffer []interface{} |
| 417 | } |
| 418 | |
| 419 | func (op *bufferWithCountOperator) next(ctx context.Context, item Item, dst chan<- Item, _ operatorOptions) { |
| 420 | op.buffer[op.iCount] = item.V |
nothing calls this directly
no outgoing calls
no test coverage detected