Source file sturdy_ref.ml

class type [+'a] t = Capnp_core.sturdy_ref

let connect t = t#connect

let connect_exn t =
  match connect t with
  | Ok x -> x
  | Error e -> failwith (Fmt.to_to_string Capnp_rpc_proto.Exception.pp e)

let reader fn s =
  fn s |> Schema.ReaderOps.string_of_pointer |> Uri.of_string

let builder fn (s : 'a Capnp.BytesMessage.StructStorage.builder_t) (sr : 'a t) =
  sr#to_uri_with_secrets |> Uri.to_string |> Schema.BuilderOps.write_string (fn s)

let cast t = t

let with_cap t f =
  match connect t with
  | Ok x -> Capability.with_ref x f
  | Error e -> Error (`Capnp e)

let with_cap_exn t f =
  let x = connect_exn t in
  Capability.with_ref x f