Package software.amazon.awssdk.awscore.eventstream

Class RestEventStreamAsyncResponseTransformer<ResponseT extends SdkResponse,EventT>

java.lang.Object

software.amazon.awssdk.awscore.eventstream.RestEventStreamAsyncResponseTransformer<ResponseT,EventT>

Type Parameters:

ResponseT - Initial response type of event stream operation.

EventT - Base type of event stream message frames.

All Implemented Interfaces:

AsyncResponseTransformer<ResponseT,Void>

@SdkProtectedApi
public class RestEventStreamAsyncResponseTransformer<ResponseT extends SdkResponse,EventT>
extends Object
implements AsyncResponseTransformer<ResponseT,Void>

Adapter transformer meant for eventstream responses from REST services (REST-XML, REST-JSON). These protocols don't have an 'initial-response' event, unlike AWS-JSON. In these protocols "initial response" is treated as the HTTP response itself. When this transformer's onResponse(SdkResponse) method is invoked, it also invokes it on the eventstream response handler, which the normal EventStreamAsyncResponseTransformer does not do.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	RestEventStreamAsyncResponseTransformer.Builder<ResponseT extends SdkResponse,EventT>	Builder for RestEventStreamAsyncResponseTransformer.

Nested classes/interfaces inherited from interface software.amazon.awssdk.core.async.AsyncResponseTransformer

AsyncResponseTransformer.SplitResult<ResponseT extends Object,ResultT extends Object>, AsyncResponseTransformer.TransformerType

Method Summary

Modifier and Type	Method	Description
static <ResponseT extends SdkResponse, EventT> RestEventStreamAsyncResponseTransformer.Builder<ResponseT,EventT>	builder()
void	exceptionOccurred(Throwable throwable)
void	onResponse(ResponseT response)
void	onStream(SdkPublisher<ByteBuffer> publisher)
CompletableFuture<Void>	prepare()

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awssdk.core.async.AsyncResponseTransformer

name, split, split

Method Details

prepare

public CompletableFuture<Void> prepare()

Specified by:

prepare in interface AsyncResponseTransformer<ResponseT extends SdkResponse,EventT>

onResponse

public void onResponse(ResponseT response)

Specified by:

onResponse in interface AsyncResponseTransformer<ResponseT extends SdkResponse,EventT>

onStream

public void onStream(SdkPublisher<ByteBuffer> publisher)

Specified by:

onStream in interface AsyncResponseTransformer<ResponseT extends SdkResponse,EventT>

exceptionOccurred

public void exceptionOccurred(Throwable throwable)

Specified by:

exceptionOccurred in interface AsyncResponseTransformer<ResponseT extends SdkResponse,EventT>

builder

public static <ResponseT extends SdkResponse,
EventT>
RestEventStreamAsyncResponseTransformer.Builder<ResponseT,EventT> builder()