code: public <T> Iterator<T> iterator( Publisher<T> pub ) {
          return iterator(pub, batchSize);
      }
docs: warning: blocks the calling thread. Need to execute in a separate thread if called
  from within a callback