Sha256: 712fa9b67f4809fe0301f41ac3d34600c689bbbb99a49bcbf7584caf58a472b9
Contents?: true
Size: 933 Bytes
Versions: 15
Compression:
Stored size: 933 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/rpcs'
require 'grpc_kit/calls/server_request_response'
module GrpcKit
module Rpcs::Server
class RequestResponse < GrpcKit::Rpcs::ServerRpc
# @param stream [GrpcKit::Stream::ServerStream]
# @param metadata [Hash<String, String>]
# @return [void]
def invoke(stream, metadata: {})
call = GrpcKit::Calls::Server::RequestResponse.new(
metadata: metadata,
config: @config,
stream: stream,
)
request = call.recv
if @config.interceptor
@config.interceptor.intercept(request, call) do
resp = @handler.send(@config.ruby_style_method_name, request, call)
call.send_msg(resp)
resp
end
else
resp = @handler.send(@config.ruby_style_method_name, request, call)
call.send_msg(resp)
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems