def next.read

mylsm-lsm-store@0.6.0.1 · src/coordinator/OwnerGenerationIo.bend:257

import mylsm-lsm-store@0.6.0.1/src/coordinator/OwnerGenerationIo.bend as OwnerGenerationIo
import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/OwnerGeneration.bend as Generation

257def next.read(
258  directory: String,
259  result: Result<&1, &1, Error, U32>
260) -> IO(Result<&1, &1, Error, U32>):
261  match result:
262    case Fail{Invalid{}}:
263      IO.pure(Result<&1, &1, Error, U32>, Fail{Invalid{}})
264    case Fail{Host{code, message}}:
265      IO.pure(Result<&1, &1, Error, U32>, Fail{Host{code, message}})
266    case Fail{Exhausted{}}:
267      IO.pure(Result<&1, &1, Error, U32>, Fail{Exhausted{}})
268    case Done{current}:
269      next.decision(directory, Generation.next(Some{current}))

Uses (9)

Used by (1)