Grpc_client
module Connection : sig ... end
val with_connection :
env:< net : [> [ `Generic | `Unix ] Eio.Net.ty ] Eio.Resource.t.. > ->
sockaddr:Eio.Net.Sockaddr.stream ->
f:(Connection.t -> 'a Base.Or_error.t) ->
'a Base.Or_error.t
val unary :
('request, 'response) Grpc_spec.unary ->
connection:Connection.t ->
'request ->
'response Base.Or_error.t
val server_streaming :
('request, 'response) Grpc_spec.server_streaming ->
connection:Connection.t ->
'request ->
'response Grpc_stream.t Base.Or_error.t
val client_streaming :
('request, 'response) Grpc_spec.client_streaming ->
connection:Connection.t ->
f:
('request Grpc_stream.Writer.t ->
'response Base.option Eio.Promise.t ->
'a) ->
'a Base.Or_error.t
val bidirectional_streaming :
('request, 'response) Grpc_spec.bidirectional_streaming ->
connection:Connection.t ->
f:('request Grpc_stream.Writer.t -> 'response Grpc_stream.t -> 'a) ->
'a Base.Or_error.t