~/jendhub

def source.tables.validated

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

import mylsm-lsm-store@0.6.0.1/src/transfer/MigrateIo.bend as MigrateIo
import Base

875def source.tables.validated(
876  state: TableValidation
877) -> IO(Result<&1, &1, Error, SourceSnapshot>):
878  match state:
879    case TableValidation{lock, path, result, records, _}:
880      match result:
881        case Fail{error}: source.release(lock, path, Fail{error})
882        case Done{sst}:
883          source.tables.present(sst, records, lock, path.clone.pair(path))

Uses (8)

Used by (1)