def snapshot.cursor.next

mylsm-lsm-store@0.6.0.1 · src/coordinator/ByteClient.bend:436

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as Client
import mylsm-lsm-store@0.6.0.1/src/coordinator/Protocol.bend as Protocol
import mylsm-lsm-store@0.6.0.1/src/coordinator/CursorCodec.bend as CursorCodec

436# Reads one raw-byte item or the terminal marker from an owner cursor.
437def snapshot.cursor.next(
438  session: Client.Session,
439  cursor_id: U32
440) -> IO(Client.Session & Result<&1, &1, Client.Error, CursorCodec.Frame>):
441  do IO<Client.Session & Result<&1, &1, Client.Error, CursorCodec.Frame>>:
442    pair : Client.Session & Result<&1, &1, Client.Error, Protocol.Response> <-
443      Client.session.call(session, 13, Protocol.snapshot.id.bytes(cursor_id))
444    return snapshot.cursor.next.result(pair)