Uses of Interface
ratpack.exec.stream.TransformablePublisher

Packages that use TransformablePublisher

Package	Description
ratpack.core.file	Types for dealing with the file system and serving files.
ratpack.core.http	The HTTP protocol.
ratpack.core.http.client	The HTTP client.
ratpack.core.sse.client
ratpack.exec.stream	Support for reactive streams.
ratpack.exec.stream.bytebuf
ratpack.exec.util
ratpack.reactor	Provides integration with the Project Reactor library.
ratpack.rx2	Provides integration with the RxJava library.

Uses of TransformablePublisher in ratpack.core.file

Methods in ratpack.core.file that return TransformablePublisher

Modifier and Type	Method	Description
static TransformablePublisher<io.netty.buffer.ByteBuf>	FileIo.readStream(Promise<? extends AsynchronousFileChannel> file, io.netty.buffer.ByteBufAllocator allocator, int bufferSize)	Streams the entire contents of a file.
static TransformablePublisher<io.netty.buffer.ByteBuf>	FileIo.readStream(Promise<? extends AsynchronousFileChannel> file, io.netty.buffer.ByteBufAllocator allocator, int bufferSize, long start, long stop)	Streams the contents of a file.

Uses of TransformablePublisher in ratpack.core.http

Methods in ratpack.core.http that return TransformablePublisher

Modifier and Type	Method	Description
TransformablePublisher<? extends io.netty.buffer.ByteBuf>	Request.getBodyStream()	Allows reading the body as a stream, with back pressure.
TransformablePublisher<? extends io.netty.buffer.ByteBuf>	Request.getBodyStream(long maxContentLength)	Allows reading the body as a stream, with back pressure.

Uses of TransformablePublisher in ratpack.core.http.client

Methods in ratpack.core.http.client that return TransformablePublisher

Modifier and Type	Method	Description
TransformablePublisher<io.netty.buffer.ByteBuf>	StreamedResponse.getBody()

Uses of TransformablePublisher in ratpack.core.sse.client

Methods in ratpack.core.sse.client that return TransformablePublisher

Modifier and Type	Method	Description
TransformablePublisher<ServerSentEvent>	ServerSentEventResponse.getEvents()	The response body parsed as events.

Uses of TransformablePublisher in ratpack.exec.stream

Methods in ratpack.exec.stream that return TransformablePublisher

Modifier and Type	Method	Description
static <T> TransformablePublisher<T>	Streams.batch(int batchSize, Publisher<T> publisher, Action<? super T> disposer)	Batches and serialised demand.
default TransformablePublisher<T>	TransformablePublisher.batch(int batchSize, Action<? super T> disposer)	See Streams.batch(int, Publisher, Action).
static <T> TransformablePublisher<T>	Streams.bindExec(Publisher<T> publisher)	Binds the given publisher to the current Execution.
static <T> TransformablePublisher<T>	Streams.bindExec(Publisher<T> publisher, Action<? super T> disposer)	Binds the given publisher to the current Execution.
default TransformablePublisher<T>	TransformablePublisher.bindExec()	See Streams.bindExec(Publisher).
default TransformablePublisher<T>	TransformablePublisher.bindExec(Action<? super T> disposer)	See Streams.bindExec(Publisher, Action).
static <T> TransformablePublisher<T>	Streams.buffer(Publisher<T> publisher)	Returns a publisher that allows the given publisher to without respecting demand.
default TransformablePublisher<T>	TransformablePublisher.buffer()	See Streams.buffer(Publisher).
static <T> TransformablePublisher<T>	Streams.concat(Iterable<? extends Publisher<? extends T>> publishers)	Similar to Streams.concat(Iterable, Action), but with a noop disposer.
static <T> TransformablePublisher<T>	Streams.concat(Iterable<? extends Publisher<? extends T>> publishers, Action<? super T> disposer)	Returns a publisher that aggregates the given publishers into a single stream of elements, without interleaving them.
static <T> TransformablePublisher<T>	Streams.constant(T item)	Creates a new publisher, that indefinitely streams the given object to all subscribers.
static <T> TransformablePublisher<T>	Streams.empty()	An empty publisher that immediately completes.
static <T> TransformablePublisher<T>	Streams.fanOut(Publisher<? extends Iterable<? extends T>> publisher)	Returns a publisher that publishes each element from Collections that are produced from the given input publisher.
static <T> TransformablePublisher<T>	Streams.fanOut(Publisher<? extends Iterable<? extends T>> publisher, Action<? super T> disposer)	Returns a publisher that publishes each element from Collections that are produced from the given input publisher.
static <T> TransformablePublisher<T>	Streams.filter(Publisher<T> input, Predicate<? super T> filter)	Returns a publisher that filters items from the given input stream by applying the given filter predicate.
default TransformablePublisher<T>	TransformablePublisher.filter(Predicate<? super T> filter)	See Streams.filter(Publisher, Predicate).
static <I,O> TransformablePublisher<O>	Streams.flatMap(Publisher<I> input, Function<? super I,? extends Promise<? extends O>> function)	Returns a publisher that publishes items from the given input publisher after transforming each item via the given, promise returning, function.
default <O> TransformablePublisher<O>	TransformablePublisher.flatMap(Function<? super T,? extends Promise<? extends O>> function)	See Streams.flatMap(Publisher, Function).
static <T> TransformablePublisher<T>	Streams.flatten(Publisher<? extends Publisher<T>> publisher)	Creates a single publisher from a publisher of publishers.
static <T> TransformablePublisher<T>	Streams.flatten(Publisher<? extends Publisher<T>> publisher, Action<? super T> disposer)	Creates a single publisher from a publisher of publishers.
static <T> TransformablePublisher<T>	Streams.flatYield(Function<? super YieldRequest,? extends Promise<T>> producer)	Creates a new publisher, backed by the given asynchronous data producing function.
static <T> TransformablePublisher<T>	Streams.fork(Publisher<T> publisher, Action<? super ExecSpec> execConfig, Action<? super T> disposer)	Consumes the given publisher eagerly in a forked execution, buffering results until ready to be consumed by this execution.
default TransformablePublisher<T>	TransformablePublisher.fork()	Consumes the given publisher eagerly in a forked execution, buffering results until ready to be consumed by this execution.
default TransformablePublisher<T>	TransformablePublisher.fork(Action<? super ExecSpec> execConfig, Action<? super T> disposer)	Consumes the given publisher eagerly in a forked execution, buffering results until ready to be consumed by this execution.
static <T> TransformablePublisher<T>	Streams.gate(Publisher<T> publisher, Action<? super Runnable> valveReceiver)	Allows requests from the subscriber of the return publisher to be withheld from the given publisher until an externally defined moment.
default TransformablePublisher<T>	TransformablePublisher.gate(Action<? super Runnable> valveReceiver)	See Streams.gate(Publisher, Action).
static <I,O> TransformablePublisher<O>	Streams.map(Publisher<I> input, Function<? super I,? extends O> function)	Returns a publisher that publishes items from the given input publisher after transforming each item via the given function.
default <O> TransformablePublisher<O>	TransformablePublisher.map(Function<? super T,? extends O> function)	See Streams.map(Publisher, Function).
static <T> TransformablePublisher<T>	Streams.merge(Publisher<? extends T>... publishers)	Returns a publisher that merges the given input publishers into a single stream of elements.
static <T> TransformablePublisher<T>	Streams.multicast(Publisher<T> publisher)	Returns a publisher that will stream events emitted from the given publisher to all of its subscribers.
default TransformablePublisher<T>	TransformablePublisher.multicast()	See Streams.multicast(Publisher).
static <T> TransformablePublisher<T>	Streams.periodically(ScheduledExecutorService executorService, Duration duration, Function<? super Integer,? extends T> producer)	Executes the given function periodically, publishing the return value to the subscriber.
static <T> TransformablePublisher<T>	Streams.periodically(Registry registry, Duration duration, Function<? super Integer,? extends T> producer)
static <T> TransformablePublisher<T>	Streams.publish(Iterable<T> iterable)	Converts an iterable to a publishable.
static <T> TransformablePublisher<T>	Streams.publish(Promise<? extends Iterable<T>> promise)	Converts a Promise for an iterable into a publishable.
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)	See Streams.streamMap(Publisher, StreamMapper).
static <T> TransformablePublisher<T>	Streams.take(long count, Publisher<T> upstreamPublisher)	Returns a publisher that emits only the first n elements from the given publisher, where n is the given count.
default TransformablePublisher<T>	TransformablePublisher.take(long count)	See Streams.take(long, Publisher).
static <T> TransformablePublisher<T>	Streams.takeWhile(Predicate<T> condition, Publisher<T> upstreamPublisher)	Returns a publisher that emits elements from the given publisher, while the condition is true.
default TransformablePublisher<T>	TransformablePublisher.takeWhile(Predicate<T> condition)	See Streams.takeWhile(Predicate, Publisher).
default <O> TransformablePublisher<O>	TransformablePublisher.transform(Function<? super TransformablePublisher<? extends T>,? extends Publisher<O>> transformer)	Convenience method to allow a non Ratpack publisher transform method to be hooked in.
static <T> TransformablePublisher<T>	Streams.transformable(Publisher<T> publisher)	Wraps the publisher in Ratpack's TransformablePublisher to make composing a pipeline easier.
static <T> TransformablePublisher<T>	Streams.wiretap(Publisher<T> publisher, Action<? super StreamEvent<T>> listener)	Allows listening to the events of the given publisher as they flow to subscribers.
default TransformablePublisher<T>	TransformablePublisher.wiretap(Action<? super StreamEvent<T>> listener)	See Streams.wiretap(Publisher, Action).
static <T> TransformablePublisher<T>	Streams.yield(Function<? super YieldRequest,? extends T> producer)	Creates a new publisher, backed by the given data producing function.

Method parameters in ratpack.exec.stream with type arguments of type TransformablePublisher

Modifier and Type	Method	Description
default <O> TransformablePublisher<O>	TransformablePublisher.transform(Function<? super TransformablePublisher<? extends T>,? extends Publisher<O>> transformer)	Convenience method to allow a non Ratpack publisher transform method to be hooked in.

Uses of TransformablePublisher in ratpack.exec.stream.bytebuf

Methods in ratpack.exec.stream.bytebuf that return TransformablePublisher

Modifier and Type	Method	Description
static TransformablePublisher<? extends io.netty.buffer.ByteBuf>	ByteBufStreams.buffer(Publisher<? extends io.netty.buffer.ByteBuf> publisher, long sizeWatermark, int maxNum)	Buffers and composes byte bufs together into composites before emitting.
static TransformablePublisher<? extends io.netty.buffer.ByteBuf>	ByteBufStreams.buffer(Publisher<? extends io.netty.buffer.ByteBuf> publisher, long sizeWatermark, int maxNum, io.netty.buffer.ByteBufAllocator alloc)	Buffers and composes byte bufs together into composites before emitting.

Uses of TransformablePublisher in ratpack.exec.util

Methods in ratpack.exec.util that return TransformablePublisher

Modifier and Type	Method	Description
TransformablePublisher<T>	Batch.publisher()	Creates a publisher that emits the promised values.
TransformablePublisher<T>	ParallelBatch.publisher()	Creates a publisher that emits the promised values.
TransformablePublisher<T>	SerialBatch.publisher()	Creates a publisher that emits the promised values.

Uses of TransformablePublisher in ratpack.reactor

Methods in ratpack.reactor that return TransformablePublisher

Modifier and Type	Method	Description
static <T> TransformablePublisher<T>	ReactorRatpack.publisher(Flux<T> flux)	Converts a Flux into a Publisher, for all of the observable's items.

Uses of TransformablePublisher in ratpack.rx2

Methods in ratpack.rx2 that return TransformablePublisher

Modifier and Type	Method	Description
static <T> TransformablePublisher<T>	RxRatpack.publisher(Observable<T> observable, BackpressureStrategy strategy)	Converts an Observable into a Publisher, for all of the observable's items.
static <T> TransformablePublisher<T>	RxRatpack.publisher(ObservableOnSubscribe<T> onSubscribe, BackpressureStrategy strategy)	Converts an Observable into a Publisher, for all of the observable's items.