streamFromInputStream method

Stream<RunOutput> streamFromInputStream(
  1. Stream<RunInput> inputStream, {
  2. CallOptions? 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

Stream<RunOutput> streamFromInputStream(
  final Stream<RunInput> inputStream, {
  final CallOptions? options,
}) {
  return inputStream.asyncExpand((final input) {
    return stream(input, options: options);
  });
}