Uses of Interface
ratpack.stream.WriteStream
-
Packages that use WriteStream Package Description ratpack.stream Support for reactive streams. -
-
Uses of WriteStream in ratpack.stream
Methods in ratpack.stream that return WriteStream Modifier and Type Method Description 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.default <O> WriteStream<O>
WriteStream. itemMap(Action<? super O> itemMapper)
Deprecated.since 1.4, useitemMap(Subscription, Action)
WriteStream<U>
StreamMapper. map(Subscription subscription, WriteStream<D> downstream)
A transform step in aPublisher
chain.Methods in ratpack.stream with parameters of type WriteStream Modifier and Type Method Description WriteStream<U>
StreamMapper. map(Subscription subscription, WriteStream<D> downstream)
A transform step in aPublisher
chain.Method parameters in ratpack.stream with type arguments of type WriteStream Modifier and Type Method Description static <U,D>
TransformablePublisher<D>Streams. streamMap(Publisher<U> input, Function<? super WriteStream<D>,? extends WriteStream<? super U>> mapper)
Deprecated.since 1.4, useStreams.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, useStreams.streamMap(Publisher, StreamMapper)
default <O> TransformablePublisher<O>
TransformablePublisher. streamMap(Function<? super WriteStream<O>,? extends WriteStream<? super T>> function)
Deprecated.since 1.4, useTransformablePublisher.streamMap(StreamMapper)
default <O> TransformablePublisher<O>
TransformablePublisher. streamMap(Function<? super WriteStream<O>,? extends WriteStream<? super T>> function)
Deprecated.since 1.4, useTransformablePublisher.streamMap(StreamMapper)
-