streamFromInputStream method

@override Stream<List<Document>> streamFromInputStream(Stream<String> inputStream, { Options? options, })

Streams the most relevant documents for the query resulting from reducing the input stream.

• inputStream - the input stream to reduce and use as the query.
• options - Retrieval options.

Implementation

@override
Stream<List<Document>> streamFromInputStream(
  final Stream<String> inputStream, {
  final Options? options,
}) async* {
  final input = await inputStream.toList();
  final reduced = reduce<String>(input);
  yield* stream(reduced, options: options);
}