@ Setup ( Level . Trial ) public void setup ( ) throws Exception { super . setup ( ExecutorType . DIRECT , ExecutorType . DIRECT , MessageSize . SMALL , MessageSize . SMALL , FlowWindowSize . LARGE , ChannelType . NIO , maxConcurrentStreams , channelCount ) ; callCounter = new AtomicLong ( ) ; completed = new AtomicBoolean ( ) ; startUnaryCalls ( maxConcurrentStreams , callCounter , completed , 1 ) ; }
Setup with direct executors small payloads and a large flow control window .