def snapshot.cursor.count.close.state

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

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

518def snapshot.cursor.count.close.state(
519  state: SnapshotCountState,
520  error: Client.Error
521) -> IO(Client.Session & Result<&1, &1, Client.Error, U32>):
522  match state:
523    case SnapshotCountNeed{session, cursor_ids, _}:
524      match cursor_ids:
525        case (cursor_id, _):
526          snapshot.cursor.count.close.resource(session, cursor_id, error)
527    case SnapshotCountFrame{pair, cursor_id, _}:
528      snapshot.cursor.count.close.pair(pair, cursor_id, error)
529    case SnapshotCountItem{session, cursor_id, _}:
530      snapshot.cursor.count.close.resource(session, cursor_id, error)