Class: TestClientInterceptor
- Inherits:
-
GRPC::ClientInterceptor
show all
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/spec/support/services.rb
Overview
For testing client interceptors
Instance Method Summary
collapse
-
#bidi_streamer(requests:, call:, method:, metadata: {}) ⇒ Object
-
#client_streamer(requests:, call:, method:, metadata: {}) ⇒ Object
-
#request_response(request:, call:, method:, metadata: {}) ⇒ Object
-
#server_streamer(request:, call:, method:, metadata: {}) ⇒ Object
#initialize
Instance Method Details
#bidi_streamer(requests:, call:, method:, metadata: {}) ⇒ Object
150
151
152
153
154
155
156
157
158
159
|
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/spec/support/services.rb', line 150
def bidi_streamer(requests:, call:, method:, metadata: {})
GRPC.logger.info("Received bidi streamer call at method #{method}" \
"with requests #{requests} for call #{call}" \
" and metadata: #{metadata}")
requests.each do |r|
GRPC.logger.info("In client interceptor: #{r}")
end
metadata['foo'] = 'bar_from_bidi_streamer'
yield
end
|
#client_streamer(requests:, call:, method:, metadata: {}) ⇒ Object
131
132
133
134
135
136
137
138
139
140
|
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/spec/support/services.rb', line 131
def client_streamer(requests:, call:, method:, metadata: {})
GRPC.logger.info("Received client streamer call at method #{method}" \
" with requests #{requests} for call #{call}" \
" and metadata: #{metadata}")
requests.each do |r|
GRPC.logger.info("In client interceptor: #{r}")
end
metadata['foo'] = 'bar_from_client_streamer'
yield
end
|
#request_response(request:, call:, method:, metadata: {}) ⇒ Object
123
124
125
126
127
128
129
|
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/spec/support/services.rb', line 123
def request_response(request:, call:, method:, metadata: {})
GRPC.logger.info("Intercepted request/response call at method #{method}" \
" with request #{request} for call #{call}" \
" and metadata: #{metadata}")
metadata['foo'] = 'bar_from_request_response'
yield
end
|
#server_streamer(request:, call:, method:, metadata: {}) ⇒ Object
142
143
144
145
146
147
148
|
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/spec/support/services.rb', line 142
def server_streamer(request:, call:, method:, metadata: {})
GRPC.logger.info("Received server streamer call at method #{method}" \
" with request #{request} for call #{call}" \
" and metadata: #{metadata}")
metadata['foo'] = 'bar_from_server_streamer'
yield
end
|