class BlockingEnumerator
Public Class Methods
new(req_size, sleep_time)
click to toggle source
# File src/ruby/pb/test/client.rb, line 218 def initialize(req_size, sleep_time) @req_size = req_size @sleep_time = sleep_time end
Public Instance Methods
each_item() { |req| ... }
click to toggle source
# File src/ruby/pb/test/client.rb, line 223 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