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 Details

    • 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