Package | Description |
---|---|
ratpack.stream |
Support for reactive streams.
|
Modifier and Type | Method and Description |
---|---|
default <O> WriteStream<O> |
WriteStream.itemMap(Action<? super O> itemMapper)
Deprecated.
since 1.4, use
itemMap(Subscription, Action) |
default <O> WriteStream<O> |
WriteStream.itemMap(Subscription subscription,
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.
|
WriteStream<U> |
StreamMapper.map(Subscription subscription,
WriteStream<D> downstream)
A transform step in a
Publisher chain. |
Modifier and Type | Method and Description |
---|---|
WriteStream<U> |
StreamMapper.map(Subscription subscription,
WriteStream<D> downstream)
A transform step in a
Publisher chain. |
Modifier and Type | Method and Description |
---|---|
default <O> TransformablePublisher<O> |
TransformablePublisher.streamMap(Function<? super WriteStream<O>,? extends WriteStream<? super T>> function)
Deprecated.
since 1.4, use
TransformablePublisher.streamMap(StreamMapper) |
default <O> TransformablePublisher<O> |
TransformablePublisher.streamMap(Function<? super WriteStream<O>,? extends WriteStream<? super T>> function)
Deprecated.
since 1.4, use
TransformablePublisher.streamMap(StreamMapper) |
static <U,D> TransformablePublisher<D> |
Streams.streamMap(Publisher<U> input,
Function<? super WriteStream<D>,? extends WriteStream<? super U>> mapper)
Deprecated.
since 1.4, use
Streams.streamMap(Publisher, StreamMapper) |
static <U,D> TransformablePublisher<D> |
Streams.streamMap(Publisher<U> input,
Function<? super WriteStream<D>,? extends WriteStream<? super U>> mapper)
Deprecated.
since 1.4, use
Streams.streamMap(Publisher, StreamMapper) |