streamFromInputStream method

@override Stream<Output> streamFromInputStream(Stream<Input> inputStream, { Options? options, })

Streams the tool's output for the input resulting from reducing the input stream.

• inputStream - the input stream to reduce and use as the input.
• options is the options to pass to the tool.

Implementation

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