(w sio.Writer, p Puller)
| 158 | func (p *pullerBatch) Values() []super.Value { return p.vals } |
| 159 | |
| 160 | func CopyPuller(w sio.Writer, p Puller) error { |
| 161 | for { |
| 162 | b, err := p.Pull(false) |
| 163 | if b == nil || err != nil { |
| 164 | return err |
| 165 | } |
| 166 | if err := WriteBatch(w, b); err != nil { |
| 167 | return err |
| 168 | } |
| 169 | b.Unref() |
| 170 | } |
| 171 | } |
| 172 | |
| 173 | func PullerReader(p Puller) sio.Reader { |
| 174 | return &pullerReader{p: p} |