Package | Description |
---|---|
ratpack.stream |
Support for reactive streams.
|
Modifier and Type | Method and Description |
---|---|
default <O> WriteStream<O> |
WriteStream.itemMap(Action<? super O> itemMapper)
Creates a new write stream that passes error and complete signals on to this stream, but passes items to the given action.
|
Modifier and Type | Method and Description |
---|---|
default <O> TransformablePublisher<O> |
TransformablePublisher.streamMap(Function<? super WriteStream<O>,? extends WriteStream<T>> function)
|
default <O> TransformablePublisher<O> |
TransformablePublisher.streamMap(Function<? super WriteStream<O>,? extends WriteStream<T>> function)
|
static <I,O> TransformablePublisher<O> |
Streams.streamMap(Publisher<I> input,
Function<? super WriteStream<O>,? extends WriteStream<I>> mapper)
Allows transforming a stream into an entirely different stream.
|
static <I,O> TransformablePublisher<O> |
Streams.streamMap(Publisher<I> input,
Function<? super WriteStream<O>,? extends WriteStream<I>> mapper)
Allows transforming a stream into an entirely different stream.
|