Class: BlockingEnumerator
- Includes:
- Grpc::Testing, Grpc::Testing::PayloadType
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/pb/test/client.rb
Constant Summary
Constants included from Grpc::Testing
Grpc::Testing::BoolValue, Grpc::Testing::ClientConfigureRequest, Grpc::Testing::ClientConfigureResponse, Grpc::Testing::EchoStatus, Grpc::Testing::Empty, Grpc::Testing::EmptyMessage, Grpc::Testing::GaugeRequest, Grpc::Testing::GaugeResponse, Grpc::Testing::GrpclbRouteType, Grpc::Testing::LoadBalancerAccumulatedStatsRequest, Grpc::Testing::LoadBalancerAccumulatedStatsResponse, Grpc::Testing::LoadBalancerStatsRequest, Grpc::Testing::LoadBalancerStatsResponse, Grpc::Testing::MemorySize, Grpc::Testing::Payload, Grpc::Testing::PayloadType, Grpc::Testing::ReconnectInfo, Grpc::Testing::ReconnectParams, Grpc::Testing::ResponseParameters, Grpc::Testing::SimpleRequest, Grpc::Testing::SimpleResponse, Grpc::Testing::StreamingInputCallRequest, Grpc::Testing::StreamingInputCallResponse, Grpc::Testing::StreamingOutputCallRequest, Grpc::Testing::StreamingOutputCallResponse
Instance Method Summary collapse
- #each_item {|req| ... } ⇒ Object
-
#initialize(req_size, sleep_time) ⇒ BlockingEnumerator
constructor
A new instance of BlockingEnumerator.
Constructor Details
#initialize(req_size, sleep_time) ⇒ BlockingEnumerator
Returns a new instance of BlockingEnumerator.
221 222 223 224 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/pb/test/client.rb', line 221 def initialize(req_size, sleep_time) @req_size = req_size @sleep_time = sleep_time end |
Instance Method Details
#each_item {|req| ... } ⇒ Object
226 227 228 229 230 231 232 233 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/grpc-1.50.0-x86_64-linux/src/ruby/pb/test/client.rb', line 226 def each_item return enum_for(:each_item) unless block_given? req_cls = StreamingOutputCallRequest req = req_cls.new(payload: Payload.new(body: nulls(@req_size))) yield req # Sleep until after the deadline should have passed sleep(@sleep_time) end |