(ctx context.Context, r io.ReaderAt)
| 135 | var _ io.ReaderAt = (*walReaderAt)(nil) |
| 136 | |
| 137 | func newWalReaderAt(ctx context.Context, r io.ReaderAt) *walReaderAt { |
| 138 | return &walReaderAt{ctx, r, atomic.Uint64{}} |
| 139 | } |
| 140 | |
| 141 | func (wr *walReaderAt) ReadAt(p []byte, off int64) (int, error) { |
| 142 | if err := wr.ctx.Err(); err != nil { |