code: private void writeObject(ObjectOutputStream out) throws IOException {
          out.writeObject(clazz);
          out.writeInt(defaultBatchSize);
          out.writeInt(queryIndex);
          out.writeObject(cursor);
          out.writeObject(generators);
          out.writeInt(generatorIndex);
          writeObjects(out);
      }
docs: Pumps may be serialized to be processed by asynchronous queues