Up
Module type
T_pipe
Signature
type
query
val
query_of_sexp :
Sexplib.Sexp.t
->
query
type
response
val
sexp_of_response :
response
->
Sexplib.Sexp.t
type
error
val
sexp_of_error :
error
->
Sexplib.Sexp.t
val
rpc : (
query
,
response
,
error
)
Async.Std.Rpc.Pipe_rpc.t
val
implementation :
Invocation.t
->
query
-> (
response
Async.Std.Pipe.Reader.t
,
error
)
Core.Std.Result.t
Async.Std.Deferred.t