software.amazon.awssdk.eventstreamrpc

Interface StreamResponse<ResponseType extends EventStreamJsonMessage,StreamRequestType extends EventStreamJsonMessage>

All Superinterfaces:

StreamEventPublisher<StreamRequestType>

All Known Implementing Classes:

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

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

Method Summary

Modifier and Type	Method and 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:

getResponse

CompletableFuture<ResponseType> getResponse()

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

Returns:

isClosed

boolean isClosed()

Tests if the stream is closed

Returns: