Method: NamedTests#client_streaming

Defined in:
src/ruby/pb/test/client.rb

#client_streaming ⇒ Object 



376
377
378
379
380
381
382
383
384
385
386
387
 
# File 'src/ruby/pb/test/client.rb', line 376

def client_streaming
  msg_sizes = [27_182, 8, 1828, 45_904]
  wanted_aggregate_size = 74_922
  reqs = msg_sizes.map do |x|
    req = Payload.new(body: nulls(x))
    StreamingInputCallRequest.new(payload: req)
  end
  resp = @stub.streaming_input_call(reqs)
  assert("#{__callee__}: aggregate payload size is incorrect") do
    wanted_aggregate_size == resp.aggregated_payload_size
  end
end