mapInputStream<RunInput extends Object, RunOutput extends Object> static method

Runnable<RunInput, RunnableOptions, RunOutput> mapInputStream<RunInput extends Object, RunOutput extends Object>(
  1. Stream<RunOutput> inputStreamMapper(
    1. Stream<RunInput> inputStream
    )
)

Creates a RunnableMapInputStream from an asynchronous generator.

A RunnableMapInputStream allows you to map the input stream to a different stream of values.

  • inputStreamMapper - the stream transformer to run.

Implementation

static Runnable<RunInput, RunnableOptions, RunOutput>
    mapInputStream<RunInput extends Object, RunOutput extends Object>(
  final Stream<RunOutput> Function(Stream<RunInput> inputStream)
      inputStreamMapper,
) {
  return RunnableMapInputStream<RunInput, RunOutput>(inputStreamMapper);
}