streamFromInputStream method

@override Stream<RunOutput> streamFromInputStream(Stream<RunInput> inputStream, { RunnableOptions? 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<RunOutput> streamFromInputStream(
  final Stream<RunInput> inputStream, {
  final RunnableOptions? options,
}) async* {
  Stream<Object?> nextStepStream;
  try {
    nextStepStream = first.streamFromInputStream(
      inputStream,
      options: first.getCompatibleOptions(options),
    );
  } on TypeError catch (e) {
    _throwInvalidInputTypeStream(e, first);
  }

  for (final step in middle) {
    try {
      nextStepStream = step.streamFromInputStream(
        nextStepStream,
        options: step.getCompatibleOptions(options),
      );
    } on TypeError catch (e) {
      _throwInvalidInputTypeStream(e, step);
    }
  }

  try {
    yield* last.streamFromInputStream(
      nextStepStream,
      options: last.getCompatibleOptions(options),
    );
  } on TypeError catch (e) {
    _throwInvalidInputTypeStream(e, last);
  }
}