def table.locked

mylsm-lsm-store@0.6.0.1 · src/transfer/MigrateIo.bend:405

import Base
import mylsm-lsm-store@0.6.0.1/src/DbLock.bend as DbLock
import mylsm-lsm-store@0.6.0.1/src/DurableError.bend as DurableError

405def table.locked(
406  path: String,
407  result: Result<&1, &1, DurableError.Error, DbLock.Lock>
408) -> IO(Result<&1, &1, Error, Nat & Nat>):
409  match result:
410    case Fail{error}:
411      IO.pure(Result<&1, &1, Error, Nat & Nat>, Fail{LockError{error}})
412    case Done{lock}:
413      do IO<Result<&1, &1, Error, Nat & Nat>>:
414        paths : String & String = path.clone.pair(path)
415        table.locked.manifest(lock, paths)