@ Setup ( Level . Trial ) public void setup ( ) throws Exception { super . setup ( ExecutorType . DIRECT , ExecutorType . DIRECT , MessageSize . SMALL , responseSize , clientInboundFlowWindow , ChannelType . NIO , maxConcurrentStreams , 1 ) ; callCounter = new AtomicLong ( ) ; completed = new AtomicBoolean ( ) ; record = new AtomicBoolean ( ) ; latch = startFlowControlledStreamingCalls ( maxConcurrentStreams , callCounter , record , completed , responseSize . bytes ( ) ) ; }
Setup with direct executors and one channel .