Grpc_client (grpc-client.Grpc

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