{@inheritDoc}

@see jcifs.smb.DirFileEntryEnumIteratorBase#fetchMore()
174621
@SuppressWarnings ( "resource" )
    @Override
    protected boolean fetchMore () throws CIFSException {
        FileEntry[] results = this.response.getResults();
        SmbTreeHandleImpl th = getTreeHandle();
        Smb2QueryDirectoryRequest query = new Smb2QueryDirectoryRequest(th.getConfig(), this.fileId);
        query.setFileName(this.getWildcard());
        query.setFileIndex(results[ results.length - 1 ].getFileIndex());
        query.setQueryFlags(Smb2QueryDirectoryRequest.SMB2_INDEX_SPECIFIED);
        try {
            Smb2QueryDirectoryResponse r = th.send(query);
            if ( r.getStatus() == NtStatus.NT_STATUS_NO_MORE_FILES ) {
                return false;
            }
            this.response = r;
        }
        catch ( SmbException e ) {
            if ( e.getNtStatus() == NtStatus.NT_STATUS_NO_MORE_FILES ) {
                log.debug("End of listing", e);
                return false;
            }
            throw e;
        }
        return true;
    }
641356
def more
      if more?
        url = Addressable::URI.parse(http_response.links[:next])
        self.class.new(
          @connection,
          url.path,
          @klass,
          @parent
        ).tap do |collection|
          collection.parameters = url.query_values
        end
      else
        raise PaginationError, %{Collection has no 'Link: <url>; rel="next"' header}
      end
    end
1216897
async def next(self, count=None):
        
        if self._next_uri is None:
            return self[:0]  # An empty slice of `self`.
        else:
            return self._fetch(self._next_uri, count)
818954
def fetchMore(self, parentIndex):  # TODO: Make LazyLoadRepoTreeModel?
        
        parentItem = self.getItem(parentIndex)
        if not parentItem:
            return

        if not parentItem.canFetchChildren():
            return

        # TODO: implement InsertItems to optimize?
        for childItem in parentItem.fetchChildren():
            self.insertItem(childItem, parentIndex=parentIndex)

        # Check that Rti implementation correctly sets canFetchChildren
        assert not parentItem.canFetchChildren(), \
            "not all children fetched: {}".format(parentItem)
277493
public static List<File> findFilesRecursive(final File dir, final String extension) {
        final String dotExtension = "." + extension;
        final List<File> files = new ArrayList<>();
        final FileProcessor fileProcessor = new FileProcessor(new FileHandler() {
            @Override
            public final FileHandlerResult handleFile(final File file) {
                // Directory
                if (file.isDirectory()) {
                    return FileHandlerResult.CONTINUE;
                }
                // File
                final String name = file.getName();
                if (name.endsWith(dotExtension)) {
                    files.add(file);
                }
                return FileHandlerResult.CONTINUE;
            }
        });

        fileProcessor.process(dir);
        return files;
    }
20076
private AbstractMessage fetchNext() throws JMSException
	{
		if (nextMessage != null)
			return nextMessage; // Already fetched
		nextMessage = localQueue.browse(cursor, parsedSelector); // Lookup next candidate
		if (nextMessage == null)
			close(); // Auto-close enumeration at end of queue
		return nextMessage;
	}
1236569
@Override
    public File findNext(RepositoryPointerImpl location, long timelimit) {
        return findNext(getChild(location.getFileId()), timelimit);
    }
902888
def next_listing(self, limit=None):
        
        if self.after:
            return self._reddit._limit_get(self._path, params={'after': self.after}, limit=limit or self._limit)
        elif self._has_literally_more:
            more = self[-1]
            data = dict(
                link_id=self[0].parent_id,
                id=more.name,
                children=','.join(more.children)
            )
            j = self._reddit.post('api', 'morechildren', data=data)
            # since reddit is inconsistent here, we're hacking it to be
            # consistent so it'll work with _thingify
            d = j['json']
            d['kind'] = 'Listing'
            d['data']['children'] = d['data']['things']
            del d['data']['things']
            return self._reddit._thingify(d, path=self._path) 
        else:
            raise NoMoreError('no more items')
880996
def next(self):
        
        try:
            return self.results.pop(0)
        except IndexError:
            if self.next_uri is None:
                raise StopIteration()
            else:
                if not self.next_uri:
                    if self.domain:
                        self.results = self.list_method(self.domain)
                    else:
                        self.results = self.list_method()
                else:
                    args = self.extra_args
                    self.results = self._list_method(self.next_uri, *args)
                self.next_uri = self.manager._paging.get(
                        self.paging_service, {}).get("next_uri")
        # We should have more results.
        try:
            return self.results.pop(0)
        except IndexError:
            raise StopIteration()
628046
private void fetchNext() {
		if (pendingUtc != null || done) {
			return;
		}

		DateValue dUtc = generateInstance();

		//check the exit condition
		if (dUtc == null || !condition.apply(dUtc)) {
			done = true;
			return;
		}

		pendingUtc = dUtc;
		yearGenerator.workDone();
	}
539755
@NonNull
    public Searcher loadMore() {
        if (!hasMoreHits()) {
            return this;
        }
        query.setPage(++lastRequestPage);
        final int currentRequestId = ++lastRequestId;
        EventBus.getDefault().post(new SearchEvent(this, query, currentRequestId));
        pendingRequests.put(currentRequestId, triggerSearch(new CompletionHandler() {
            @Override
            public void requestCompleted(@NonNull JSONObject content, @Nullable AlgoliaException error) {
                pendingRequests.remove(currentRequestId);
                if (error != null) {
                    postError(error, currentRequestId);
                } else {
                    if (currentRequestId <= lastResponseId) {
                        return; // Hits are for an older query, let's ignore them
                    }

                    if (hasHits(content)) {
                        updateListeners(content, true);
                        updateFacetStats(content);
                        lastResponsePage = lastRequestPage;

                        checkIfLastPage(content);
                    } else {
                        endReached = true;
                    }
                    EventBus.getDefault().post(new ResultEvent(Searcher.this, content, query, currentRequestId));
                }
            }
        }));
        return this;
    }
826710
public function getMore($col, $id, $number, $conn)
    {
        if (mb_orig_strpos($col, '.') === false) {
            $col = $this->dbname . '.' . $col;
        }

        $this->request(
            self::OP_GETMORE,
            "\x00\x00\x00\x00" . $col . "\x00" . pack('V', $number) . $id,
            false,
            $conn,
            function ($conn, $reqId = null) use ($id) {
                if (!$conn) {
                    !$cb || $cb(['$err' => 'Connection error.']);
                    return;
                }
                $conn->requests[$reqId] = [$id];
            }
        );
    }
1081511
def fetch(self, limit, offset=0):
        """"""
        self.limit = limit
        self.offset = offset
        return self
659585
private void fetch() {
    	next.clear();
        // We need to remember for what thread the IEnumVARIANT was marshaled. Because if we want to interpret this
        // VARIANT as an interface pointer later on, we need to do this in the same thread!
        next.thread = e.getComThread();
        int r = e.next(1,next);
        if(r==0) {
            next = null;
            e.dispose();
        }
    }
1013868
@Override
	public void getNext(CAS cas) throws IOException, CollectionException {
		if(mCurrentIndex == 0) {
			logger.info("Reading collection {} ({} documents)", inputDirPath, mFiles.size());
			progressLoggerTimer.schedule(new TimerTask() {
				private long lastSize = 0;
				private long lastTop = System.currentTimeMillis();
				
				@Override
				public void run() {
					long top = System.currentTimeMillis();
					long size = currentFileByteSize;
					AbstractTermSuiteCollectionReader.logger.info("{}% - {} processed out of {} ({} Mb/s) - Processing file {} (doc. {} out of {})", 
							String.format("%.2f", ((float)currentFileByteSize*100)/totalFileByteSize),
							fr.univnantes.termsuite.utils.FileUtils.humanReadableByteCount(currentFileByteSize, true),
							fr.univnantes.termsuite.utils.FileUtils.humanReadableByteCount(totalFileByteSize, true),
							String.format("%.2f", 0.001*((float)size-lastSize)/((float)Math.max(1, top-lastTop))),
							mFiles.get(mCurrentIndex).getName(),
							mCurrentIndex,
							mFiles.size()
							);
					lastSize = size;
					lastTop = top;
				}
			}, 5000l, 5000l);
		}
		File file = mFiles.get(mCurrentIndex++);
		this.currentFileByteSize += file.length();
		
		logger.debug("Reading file ("+this.mCurrentIndex+"/"+this.mFiles.size()+") " + file.getAbsolutePath());
		fillCas(cas, file);
		if(!hasNext())
			this.lastFileRead();
	}
911620
boolean getMoreResults(int current) throws SQLException {
        checkClosed();

        if (resultIn == null || !resultIn.isData()) {
            return false;
        }

        if (resultSetCounter == 0) {
            resultSetCounter++;
            return true;
        }

        if (currentResultSet != null && current != KEEP_CURRENT_RESULT) {
            currentResultSet.close();
        }

        resultIn = null;

        return false;
    }
1098106
@Override
    protected Path findNext(){
        E elem = delegate.next();
        return elem==null ? null : path.append(elem, index()+1);
    }