Source file `persistent_connection.ml`

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
open! Core
open! Async_rpc_kernel

module Uri = struct
  module T = struct
    include Uri

    let to_string s = Uri.to_string s
  end

  include T
  include Sexpable.Of_stringable (T)
end

module Rpc = struct
  include Persistent_connection.Rpc

  let create_from_uri = Persistent_connection.Rpc.create ~address:(module Uri)

  let create_from_uri_option =
    Persistent_connection.Rpc.create
      ~address:
        (module struct
          type t = Uri.t option [@@deriving equal, sexp]
        end)
  ;;
end

module Versioned_rpc = Async_rpc_kernel.Persistent_connection.Versioned_rpc