def Bytes.scan_seek.ids

mylsm-lsm-store@0.6.0.1 · mylsm.bend:1729

import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as PackedBytes
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as OwnerClient
import mylsm-lsm-store@0.6.0.1/src/coordinator/ByteClient.bend as OwnerByteClient

1729def Bytes.scan_seek.ids(
1730  session: OwnerClient.Session,
1731  snapshot_id: U32,
1732  ids: U32 & U32,
1733  lower: Maybe<&1, PackedBytes.Bytes>
1734) -> IO(Bytes.Cursor & Result<&1, &1, Bytes.Error, Unit>):
1735  match ids:
1736    case (request_id, cursor_id):
1737      do IO<Bytes.Cursor & Result<&1, &1, Bytes.Error, Unit>>:
1738        pair : OwnerClient.Session & Result<&1, &1, OwnerClient.Error, Unit> <-
1739          OwnerByteClient.snapshot.cursor.seek(session, request_id, lower)
1740        return Bytes.scan_seek.remote(snapshot_id, cursor_id, pair)