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
open! Core
open! Async_kernel
include Persistent_connection_kernel

module Versioned_rpc = Make (struct
  type t = Versioned_rpc.Connection_with_menu.t

  let rpc_connection = Versioned_rpc.Connection_with_menu.connection
  let close t = Rpc.Connection.close (rpc_connection t)
  let is_closed t = Rpc.Connection.is_closed (rpc_connection t)
  let close_finished t = Rpc.Connection.close_finished (rpc_connection t)
end)

module Rpc = Make (struct
  type t = Rpc.Connection.t

  let close t = Rpc.Connection.close t
  let is_closed t = Rpc.Connection.is_closed t
  let close_finished t = Rpc.Connection.close_finished t
end)