Interface StreamEventPublisher<StreamEventType extends EventStreamJsonMessage>
-
- Type Parameters:
StreamEventType- Data to push over the open stream
- All Known Subinterfaces:
StreamResponse<ResponseType,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 StreamEventPublisher<StreamEventType extends EventStreamJsonMessage>Interface to enable sending events over an open stream operation.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<Void>closeStream()Closes the stream by sending an empty messageCompletableFuture<Void>sendStreamEvent(StreamEventType streamEvent)Publish an event over an open stream operation.
-
-
-
Method Detail
-
sendStreamEvent
CompletableFuture<Void> sendStreamEvent(StreamEventType streamEvent)
Publish an event over an open stream operation.- Parameters:
streamEvent- event to publish- Returns:
- Completable future indicating flush of the event over the stream
-
closeStream
CompletableFuture<Void> closeStream()
Closes the stream by sending an empty message- Returns:
- Completable future indicating flush of the stream termination message
-
-