mirror of
https://github.com/zap-proto/ocaml-rpc.git
synced 2026-10-30 15:04:28 +00:00
Thomas Leonard
48d675b10e
This switches capnp-rpc from Lwt to Eio. One particularly nice side effect of this is that `Service.return_lwt` has gone, as there is no distinction now between concurrent and non-concurrent service methods.
26 lines
652 B
OCaml
26 lines
652 B
OCaml
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
|