• Home
  • Raw
  • Download

Lines Matching full:call

50   def an_rpc(req, call)  argument
52 call.output_metadata.update(@trailing_metadata)
53 @received_md << call.metadata unless call.metadata.nil?
57 def a_client_streaming_rpc(call) argument
58 # iterate through requests so call can complete
59 call.output_metadata.update(@trailing_metadata)
60 call.each_remote_read.each do |r|
66 def a_server_streaming_rpc(_req, call) argument
67 call.output_metadata.update(@trailing_metadata)
71 def a_bidi_rpc(requests, call) argument
72 call.output_metadata.update(@trailing_metadata)
84 def request_response(request:, call:, method:) argument
85 GRPC.logger.info("Received request/response call at method #{method}" \
86 " with request #{request} for call #{call}")
87 call.output_metadata[:interc] = 'from_request_response'
92 def client_streamer(call:, method:) argument
93 call.output_metadata[:interc] = 'from_client_streamer'
94 call.each_remote_read.each do |r|
98 "Received client streamer call at method #{method} for call #{call}"
103 def server_streamer(request:, call:, method:) argument
104 GRPC.logger.info("Received server streamer call at method #{method} with request" \
105 " #{request} for call #{call}")
106 call.output_metadata[:interc] = 'from_server_streamer'
110 def bidi_streamer(requests:, call:, method:) argument
114 GRPC.logger.info("Received bidi streamer call at method #{method} with requests" \
115 " #{requests} for call #{call}")
116 call.output_metadata[:interc] = 'from_bidi_streamer'
123 def request_response(request:, call:, method:, metadata: {}) argument
124 GRPC.logger.info("Intercepted request/response call at method #{method}" \
125 " with request #{request} for call #{call}" \
131 def client_streamer(requests:, call:, method:, metadata: {}) argument
132 GRPC.logger.info("Received client streamer call at method #{method}" \
133 " with requests #{requests} for call #{call}" \
142 def server_streamer(request:, call:, method:, metadata: {}) argument
143 GRPC.logger.info("Received server streamer call at method #{method}" \
144 " with request #{request} for call #{call}" \
150 def bidi_streamer(requests:, call:, method:, metadata: {}) argument
151 GRPC.logger.info("Received bidi streamer call at method #{method}" \
152 "with requests #{requests} for call #{call}" \