Grpc_server.Rpc
val unary :
('request, Grpc_spec.Value_mode.unary, 'response, Grpc_spec.Value_mode.unary)
Grpc_spec.t ->
f:('request -> 'response) ->
t
val client_streaming :
('request,
Grpc_spec.Value_mode.stream,
'response,
Grpc_spec.Value_mode.unary)
Grpc_spec.t ->
f:('request Grpc_stream.t -> 'response) ->
t
val server_streaming :
('request,
Grpc_spec.Value_mode.unary,
'response,
Grpc_spec.Value_mode.stream)
Grpc_spec.t ->
f:('request -> send_response:('response -> Base.unit) -> Base.unit) ->
t
val bidirectional_streaming :
('request,
Grpc_spec.Value_mode.stream,
'response,
Grpc_spec.Value_mode.stream)
Grpc_spec.t ->
f:
('request Grpc_stream.t ->
send_response:('response -> Base.unit) ->
Base.unit) ->
t