performDocumentSearchChunked method

Stream<QueryResult> performDocumentSearchChunked(
  1. DocumentSearchChunkedRequest request
)

Implementation

Stream<QueryResult> performDocumentSearchChunked(
  DocumentSearchChunkedRequest request,
) async* {
  // Read all documents into memory
  final last = await performDocumentSearch(DocumentSearchRequest(
    collection: request.collection,
    query: request.query,
    reach: request.reach,
  )).last;

  // Yield them
  yield (last);
}