public static final class SplittingTransformer.Builder<ResponseT,ResultT> extends Object
| Modifier and Type | Method and Description |
|---|---|
SplittingTransformer<ResponseT,ResultT> |
build() |
SplittingTransformer.Builder<ResponseT,ResultT> |
maximumBufferSizeInBytes(Long maximumBufferSize)
The amount of data in byte this publisher will buffer into memory before sending it to the upstream transformer.
|
SplittingTransformer.Builder<ResponseT,ResultT> |
resultFuture(CompletableFuture<ResultT> returnFuture)
The future that will be completed when the future which is returned by the call to
AsyncResponseTransformer.prepare() completes. |
SplittingTransformer.Builder<ResponseT,ResultT> |
upstreamResponseTransformer(AsyncResponseTransformer<ResponseT,ResultT> upstreamResponseTransformer)
The
AsyncResponseTransformer that will receive the data from each of the individually published
IndividualTransformer, usually intended to be the one on which the
AsyncResponseTransformer.split(SplittingTransformerConfiguration))} method was called. |
public SplittingTransformer.Builder<ResponseT,ResultT> upstreamResponseTransformer(AsyncResponseTransformer<ResponseT,ResultT> upstreamResponseTransformer)
AsyncResponseTransformer that will receive the data from each of the individually published
IndividualTransformer, usually intended to be the one on which the
AsyncResponseTransformer.split(SplittingTransformerConfiguration))} method was called.upstreamResponseTransformer - the AsyncResponseTransformer that was split.public SplittingTransformer.Builder<ResponseT,ResultT> maximumBufferSizeInBytes(Long maximumBufferSize)
maximumBufferSize to the upstream transformer unless the subscription is
cancelled while less amount is buffered, in which case a chunk with a size less than maximumBufferSize will be
sent.maximumBufferSize - the amount of data buffered and the size of the chunk of datapublic SplittingTransformer.Builder<ResponseT,ResultT> resultFuture(CompletableFuture<ResultT> returnFuture)
AsyncResponseTransformer.prepare() completes.returnFuture - the future to complete.public SplittingTransformer<ResponseT,ResultT> build()
Copyright © 2026. All rights reserved.