@ Setup ( Level . Trial ) public void setup ( ) throws Exception { super . setup ( clientExecutor , ExecutorType . DIRECT , MessageSize . SMALL , responseSize , FlowWindowSize . MEDIUM , ChannelType . NIO , maxConcurrentStreams , channelCount ) ; callCounter = new AtomicLong ( ) ; completed = new AtomicBoolean ( ) ; record = new AtomicBoolean ( ) ; latch = startFlowControlledStreamingCalls ( maxConcurrentStreams , callCounter , record , completed , 1 ) ; }
Setup with direct executors small payloads and the default flow - control window .