Class: GrpcKit::Rpcs::Client::BidiStreamer
- Inherits:
-
GrpcKit::Rpcs::ClientRpc
- Object
- GrpcKit::Rpcs::ClientRpc
- GrpcKit::Rpcs::Client::BidiStreamer
- Defined in:
- lib/grpc_kit/rpcs/client_bidi_streamer.rb
Instance Attribute Summary
Attributes inherited from GrpcKit::Rpcs::ClientRpc
Instance Method Summary collapse
Methods inherited from GrpcKit::Rpcs::ClientRpc
Constructor Details
This class inherits a constructor from GrpcKit::Rpcs::ClientRpc
Instance Method Details
#invoke(stream, _requests, metadata: {}, timeout: nil) ⇒ GrpcKit::Calls::Client::BidiStreamer
14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
# File 'lib/grpc_kit/rpcs/client_bidi_streamer.rb', line 14 def invoke(stream, _requests, metadata: {}, timeout: nil) call = GrpcKit::Calls::Client::BidiStreamer.new( metadata: , config: @config, timeout: timeout, stream: stream, ) if @config.interceptor @config.interceptor.intercept(call, ) { |c| c } else call end end |