@Override public int put(final List<T> buffer,final int from,final int to) throws IOException {
  int i=from;
  while (i < to && queue.offer(buffer.get(i))) {
    i++;
  }
  return i - from;
}

@ Override public int put ( final List < T > buffer , final int from , final int to ) throws IOException { int i = from ; while ( i < to && queue . offer ( buffer . get ( i ) ) ) { i ++ ; } return i - from ; }
non - blocking bulk put implementation
