def append.opened

mylsm-lsm-store@0.6.0.1 · src/ByteWalIo.bend:623

import Base
import mylsm-lsm-store@0.6.0.1/src/CrashPoint.bend as CrashPoint
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

623def append.opened(
624  opened: Result<&1, &1, U32 & String, File>,
625  frame: Bytes.Bytes,
626  +path: String
627) -> IO(Result<&1, &1, U32 & String, Unit>):
628  match opened:
629    case Fail{failure}:
630      IO.pure(Result<&1, &1, U32 & String, Unit>, Fail{failure})
631    case Done{file}:
632      do IO<Result<&1, &1, U32 & String, Unit>>:
633        _checkpoint : Result<&1, &1, U32 & String, Unit> <-
634          CrashPoint.hit("wal.before_append")
635        append.opened.frame(file, frame, path)