Package software.amazon.awssdk.aws.greengrass

Class PublishToTopicResponseHandler

java.lang.Object

software.amazon.awssdk.aws.greengrass.PublishToTopicResponseHandler

All Implemented Interfaces:

StreamEventPublisher<EventStreamJsonMessage>, StreamResponse<PublishToTopicResponse,EventStreamJsonMessage>

public final class PublishToTopicResponseHandler
extends Object
implements StreamResponse<PublishToTopicResponse,EventStreamJsonMessage>

Constructor Summary

Constructors

Constructor	Description
PublishToTopicResponseHandler(OperationResponse<PublishToTopicResponse,EventStreamJsonMessage> operationResponse)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	closeStream()	Closes the stream by sending an empty message
CompletableFuture<Void>	getRequestFlushFuture()	Completable future indicating flush of the request that initiated the stream operation
CompletableFuture<PublishToTopicResponse>	getResponse()	Completable future for retrieving the initial-response of the stream operation
boolean	isClosed()	Tests if the stream is closed
CompletableFuture<Void>	sendStreamEvent(EventStreamJsonMessage event)	Publish an event over an open stream operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

PublishToTopicResponseHandler

public PublishToTopicResponseHandler(OperationResponse<PublishToTopicResponse,EventStreamJsonMessage> operationResponse)

Method Detail

getRequestFlushFuture

public CompletableFuture<Void> getRequestFlushFuture()

Description copied from interface: StreamResponse

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

Specified by:

getRequestFlushFuture in interface StreamResponse<PublishToTopicResponse,EventStreamJsonMessage>

Returns:

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

getResponse

public CompletableFuture<PublishToTopicResponse> getResponse()

Description copied from interface: StreamResponse

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

Specified by:

getResponse in interface StreamResponse<PublishToTopicResponse,EventStreamJsonMessage>

Returns:

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

sendStreamEvent

public CompletableFuture<Void> sendStreamEvent(EventStreamJsonMessage event)

Description copied from interface: StreamEventPublisher

Publish an event over an open stream operation.

Specified by:

sendStreamEvent in interface StreamEventPublisher<EventStreamJsonMessage>

Parameters:

event - event to publish

Returns:

Completable future indicating flush of the event over the stream

closeStream

public CompletableFuture<Void> closeStream()

Description copied from interface: StreamEventPublisher

Closes the stream by sending an empty message

Specified by:

closeStream in interface StreamEventPublisher<EventStreamJsonMessage>

Returns:

Completable future indicating flush of the stream termination message

isClosed

public boolean isClosed()

Description copied from interface: StreamResponse

Tests if the stream is closed

Specified by:

isClosed in interface StreamResponse<PublishToTopicResponse,EventStreamJsonMessage>

Returns:

True if the stream is closed