def scan.sources.opened

mylsm-lsm-store@0.6.0.1 · src/ByteDurableDb.bend:2195

import Base
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import mylsm-lsm-store@0.6.0.1/src/scan/SstCursor.bend as SstCursor
import mylsm-lsm-store@0.6.0.1/src/scan/RangeCursor.bend as RangeCursor
import mylsm-lsm-store@0.6.0.1/src/scan/VisibleCursor.bend as VisibleCursor

2195def scan.sources.opened(
2196  handle: Handle,
2197  delta: List<&1, ByteMemTable.Entry>,
2198  bounds: RangeCursor.Bounds,
2199  opened: Result<&1, &1, U32 & String, SstCursor.Cursor>
2200) -> IO(Handle & Result<&1, &1, Error, VisibleCursor.Cursor>):
2201  match opened:
2202    case Fail{(code, message)}:
2203      IO.pure(Handle & Result<&1, &1, Error, VisibleCursor.Cursor>,
2204        (handle, Fail{recovery.error(code, message)}))
2205    case Done{base}:
2206      IO.pure(Handle & Result<&1, &1, Error, VisibleCursor.Cursor>,
2207        (handle, Done{VisibleCursor.open(Some{base}, delta, bounds)}))