readDelta returns only the bytes appended after the last readDelta call.
()
| 466 | // readDelta returns only the bytes appended |
| 467 | // after the last readDelta call. |
| 468 | func (d *deltaBuffer) readDelta() []byte { |
| 469 | d.mu.Lock() |
| 470 | defer d.mu.Unlock() |
| 471 | |
| 472 | b := bytes.Clone(d.buf.Bytes()) |
| 473 | d.buf.Reset() |
| 474 | return b |
| 475 | } |