Package | Description |
---|---|
ratpack.stream |
Support for reactive streams.
|
Modifier and Type | Method and Description |
---|---|
static <U,D> TransformablePublisher<D> |
Streams.streamMap(Publisher<? extends U> input,
StreamMapper<? super U,D> mapper)
Allows transforming a stream into an entirely different stream.
|
default <O> TransformablePublisher<O> |
TransformablePublisher.streamMap(StreamMapper<? super T,O> mapper)
|