streamFromInputStream method

@override Stream<String> streamFromInputStream(Stream<ParserInput> inputStream, { OutputParserOptions? options, })

Streams the output of invoking the Runnable on the given inputStream.

• inputStream - the input stream to invoke the Runnable on.
• options - the options to use when invoking the Runnable.

Implementation

@override
Stream<String> streamFromInputStream(
  final Stream<ParserInput> inputStream, {
  final OutputParserOptions? options,
}) async* {
  if (reduceOutputStream) {
    yield await inputStream.map(_parse).reduce((final a, final b) => '$a$b');
  } else {
    yield* inputStream.map(_parse);
  }
}