static void poolSize(int size){
  if (size > 0) {
    outPool=new LinkedBlockingQueue<>(size);
    inPool=new LinkedBlockingQueue<>(size);
    for (int i=0; i < size; i++) {
      outPool.offer(createOut());
      inPool.offer(createIn());
    }
  }
 else {
    outPool=null;
    inPool=null;
  }
}

static void poolSize ( int size ) { if ( size > 0 ) { outPool = new LinkedBlockingQueue < > ( size ) ; inPool = new LinkedBlockingQueue < > ( size ) ; for ( int i = 0 ; i < size ; i ++ ) { outPool . offer ( createOut ( ) ) ; inPool . offer ( createIn ( ) ) ; } } else { outPool = null ; inPool = null ; } }
sets streams pool size .
