(ctx context.Context, sctx *super.Context, head, tail ID)
| 187 | } |
| 188 | |
| 189 | func (q *Queue) OpenAsBSUP(ctx context.Context, sctx *super.Context, head, tail ID) (*bsupio.Reader, error) { |
| 190 | r, err := q.Open(ctx, head, tail) |
| 191 | if err != nil { |
| 192 | return nil, err |
| 193 | } |
| 194 | return bsupio.NewReader(sctx, r), nil |
| 195 | } |
| 196 | |
| 197 | func writeID(ctx context.Context, engine storage.Engine, u *storage.URI, id ID) error { |
| 198 | r := strings.NewReader(strconv.FormatUint(uint64(id), 10)) |