def snapshot.cursor.count.close.pair

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

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/CursorCodec.bend as CursorCodec

509def snapshot.cursor.count.close.pair(
510  pair: Client.Session & Result<&1, &1, Client.Error, CursorCodec.Frame>,
511  cursor_id: U32,
512  error: Client.Error
513) -> IO(Client.Session & Result<&1, &1, Client.Error, U32>):
514  match pair:
515    case (session, _):
516      snapshot.cursor.count.close.resource(session, cursor_id, error)