com.ibm.cos.v2.core.internal.async

Class SplittingTransformer<ResponseT,ResultT>

java.lang.Object

com.ibm.cos.v2.core.internal.async.SplittingTransformer<ResponseT,ResultT>

All Implemented Interfaces:

SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>, org.reactivestreams.Publisher<AsyncResponseTransformer<ResponseT,ResponseT>>

public class SplittingTransformer<ResponseT,ResultT>
extends Object
implements SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>

Split a AsyncResponseTransformer into multiple ones, publishing them as a SdkPublisher. Created using the split method. The upstream AsyncResponseTransformer that is split will receive data from the individual transformers.

This publisher also buffers an amount of data before sending it to the upstream transformer, as specified by the maximumBufferSize. ByteBuffers will be published once the buffer has been reached, or when the subscription to this publisher is cancelled.

Cancelling the subscription to this publisher signals that no more data needs to be sent to the upstream transformer. This publisher will then send all data currently buffered to the upstream transformer and complete the downstream subscriber.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SplittingTransformer.Builder<ResponseT,ResultT>

Method Summary

Modifier and Type	Method and Description
static <ResponseT,ResultT> SplittingTransformer.Builder<ResponseT,ResultT>	builder()
void	subscribe(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<ResponseT,ResponseT>> downstreamSubscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.ibm.cos.v2.core.async.SdkPublisher

adapt, addTrailingData, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, fromIterable, limit, map, subscribe

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<ResponseT,ResponseT>> downstreamSubscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<AsyncResponseTransformer<ResponseT,ResponseT>>

Parameters:

downstreamSubscriber - the Subscriber to the individual AsyncResponseTransformer

builder

public static <ResponseT,ResultT> SplittingTransformer.Builder<ResponseT,ResultT> builder()