| /external/grpc-grpc/src/ruby/spec/generic/ |
| rpc_desc_spec.rb | 31 @server_streamer = RpcDesc.new('ss', Object.new, Stream.new(Object.new),
154 @server_streamer.run_server_method(@call, method(:fake_svstream))
229 it 'raises when a server_streamer does not have 2 args' do
232 @server_streamer.assert_arity_matches(method(mth))
238 it 'passes when a server_streamer has 2 args' do
240 @server_streamer.assert_arity_matches(method(:fake_svstream))
290 expect(@server_streamer.request_response?).to be(false)
298 expect(@server_streamer.client_streamer?).to be(false)
303 describe '#server_streamer?' do
305 expect(@server_streamer.server_streamer?).to be(true
[all...] |
| client_interceptors_spec.rb | 85 expect(interceptor).to receive(:server_streamer)
91 expect_any_instance_of(GRPC::ActiveCall).to receive(:server_streamer)
101 expect(interceptor).to receive(:server_streamer)
107 expect_any_instance_of(GRPC::ActiveCall).to receive(:server_streamer)
|
| server_interceptors_spec.rb | 106 expect(interceptor).to receive(:server_streamer)
119 expect(interceptor).to receive(:server_streamer)
125 receive(:server_streamer).with(request)
|
| client_stub_spec.rb | 453 describe '#server_streamer', server_streamer: true do
539 e = stub.server_streamer(@method, @sent_msg, noop, unmarshal,
553 @op = stub.server_streamer(@method, @sent_msg, noop, unmarshal,
[all...] |
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| rpc_desc.rb | 89 :server_streamer,
125 elsif server_streamer?
164 elsif request_response? || server_streamer?
183 def server_streamer?
|
| interceptors.rb | 72 def server_streamer(request: nil, call: nil, method: nil, metadata: nil) method in class:GRPC.ClientInterceptor
130 def server_streamer(request: nil, call: nil, method: nil) method in class:GRPC.ServerInterceptor
|
| client_stub.rb | 260 # server_streamer sends one request to the GRPC server, which yields a
316 def server_streamer(method, req, marshal, unmarshal, method in class:GRPC.ClientStub
336 # as a new method for this instance that invokes #server_streamer
340 interception_context.intercept!(:server_streamer, intercept_args) do
341 c.server_streamer(req, &blk)
346 interception_context.intercept!(:server_streamer, intercept_args) do
347 c.server_streamer(req, metadata: metadata, &blk)
|
| service.rb | 177 elsif desc.server_streamer?
180 server_streamer(route, req, marshal, unmarshal, metadata, &blk)
|
| active_call.rb | 422 # server_streamer sends one request to the GRPC server, which yields a
436 def server_streamer(req, metadata: {}) method in class:GRPC.ActiveCall
|
| /external/grpc-grpc/src/ruby/spec/support/ |
| services.rb | 96 def server_streamer(request:, call:, method:) method in class:TestServerInterceptor
135 def server_streamer(request:, call:, method:, metadata: {}) method in class:TestClientInterceptor
|
