def Bytes.owner.wait.canonical

mylsm-lsm-store@0.6.0.1 · mylsm.bend:439

import Base

439def Bytes.owner.wait.canonical(
440  timeout_ms: U32,
441  backoff_ms: U32,
442  result: Result<&1, &1, U32 & String, String>
443) -> IO(Result<&1, &1, Bytes.Error, Bytes.Handle>):
444  match result:
445    case Fail{(code, message)}:
446      IO.pure(Result<&1, &1, Bytes.Error, Bytes.Handle>,
447        Fail{Io{code, message}})
448    case Done{canonical}:
449      Bytes.owner.wait.located(Bytes.endpoint.path.pair(canonical),
450        timeout_ms, backoff_ms)