class BlockingEnumerator

Public Class Methods

new(req_size, sleep_time) click to toggle source
# File src/ruby/pb/test/client.rb, line 221
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 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