| 158 | } |
| 159 | |
| 160 | type closePuller struct { |
| 161 | p sbuf.Puller |
| 162 | c io.Closer |
| 163 | } |
| 164 | |
| 165 | func (c *closePuller) Pull(done bool) (sbuf.Batch, error) { |
| 166 | batch, err := c.p.Pull(done) |
nothing calls this directly
no outgoing calls
no test coverage detected