Package software.amazon.awssdk.eventstreamrpc

Interface StreamResponse<ResponseType extends EventStreamJsonMessage,StreamRequestType extends EventStreamJsonMessage>

All Superinterfaces:

StreamEventPublisher<StreamRequestType>

All Known Implementing Classes:

AuthorizeClientDeviceActionResponseHandler, CancelLocalDeploymentResponseHandler, CreateDebugPasswordResponseHandler, CreateLocalDeploymentResponseHandler, DeferComponentUpdateResponseHandler, DeleteThingShadowResponseHandler, GetClientDeviceAuthTokenResponseHandler, GetComponentDetailsResponseHandler, GetConfigurationResponseHandler, GetLocalDeploymentStatusResponseHandler, GetSecretValueResponseHandler, GetThingShadowResponseHandler, ListComponentsResponseHandler, ListLocalDeploymentsResponseHandler, ListNamedShadowsForThingResponseHandler, OperationResponse, PauseComponentResponseHandler, PublishToIoTCoreResponseHandler, PublishToTopicResponseHandler, PutComponentMetricResponseHandler, RestartComponentResponseHandler, ResumeComponentResponseHandler, SendConfigurationValidityReportResponseHandler, StopComponentResponseHandler, SubscribeToCertificateUpdatesResponseHandler, SubscribeToComponentUpdatesResponseHandler, SubscribeToConfigurationUpdateResponseHandler, SubscribeToIoTCoreResponseHandler, SubscribeToTopicResponseHandler, SubscribeToValidateConfigurationUpdatesResponseHandler, UpdateConfigurationResponseHandler, UpdateStateResponseHandler, UpdateThingShadowResponseHandler, ValidateAuthorizationTokenResponseHandler, VerifyClientDeviceIdentityResponseHandler

public interface StreamResponse<ResponseType extends EventStreamJsonMessage,StreamRequestType extends EventStreamJsonMessage>
extends StreamEventPublisher<StreamRequestType>

Interface for stream responses

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	getRequestFlushFuture()	Completable future indicating flush of the request that initiated the stream operation
CompletableFuture<ResponseType>	getResponse()	Completable future for retrieving the initial-response of the stream operation
boolean	isClosed()	Tests if the stream is closed

Methods inherited from interface software.amazon.awssdk.eventstreamrpc.StreamEventPublisher

closeStream, sendStreamEvent

Method Detail

getRequestFlushFuture

CompletableFuture<Void> getRequestFlushFuture()

Completable future indicating flush of the request that initiated the stream operation

Returns:

Completable future indicating flush of the request that initiated the stream operation

getResponse

CompletableFuture<ResponseType> getResponse()

Completable future for retrieving the initial-response of the stream operation

Returns:

Completable future for retrieving the initial-response of the stream operation

isClosed

boolean isClosed()

Tests if the stream is closed

Returns:

True if the stream is closed