Module Msgpack_rpc.Make

Parameters

• M : Connection

Signature

type conn = M.t

type t

val subscribe : t -> Core_kernel.Source_code_position.t -> event Async_kernel.Pipe.Reader.t

val call : t -> method_name:string -> parameters:Msgpack.t -> (Msgpack.t, Msgpack.t) Async_kernel.Deferred.Result.t

val connect : conn -> t

val register_method : name:string -> f:(Msgpack.t list -> Msgpack.t Core_kernel.Or_error.t) -> unit Core_kernel.Or_error.t