def source.read.result

mylsm-lsm-store@0.6.0.1 · src/transfer/RestoreIo.bend:460

import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

460def source.read.result(
461  +destination: String,
462  +expected_size: Nat,
463  pair: File & Result<&1, &1, U32 & String, Bytes.Bytes>
464) -> IO(Result<&1, &1, Error, Unit>):
465  match pair:
466    case (file, Fail{(code, message)}):
467      do IO<Result<&1, &1, Error, Unit>>:
468        _closed : Unit <- File.close(file)
469        return Fail{Io{code, message}}
470    case (file, Done{input}):
471      do IO<Result<&1, &1, Error, Unit>>:
472        _closed : Unit <- File.close(file)
473        source.read.checked(destination, expected_size, input)