Package software.amazon.awssdk.aws.greengrass

Class SubscribeToTopicResponseHandler

java.lang.Object

software.amazon.awssdk.aws.greengrass.SubscribeToTopicResponseHandler

All Implemented Interfaces:

StreamEventPublisher<EventStreamJsonMessage>, StreamResponse<SubscribeToTopicResponse,EventStreamJsonMessage>

public final class SubscribeToTopicResponseHandler
extends Object
implements StreamResponse<SubscribeToTopicResponse,EventStreamJsonMessage>

Constructor Summary

Constructors

Constructor	Description
SubscribeToTopicResponseHandler(OperationResponse<SubscribeToTopicResponse,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<SubscribeToTopicResponse>	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 Details

SubscribeToTopicResponseHandler

public SubscribeToTopicResponseHandler(OperationResponse<SubscribeToTopicResponse,EventStreamJsonMessage> operationResponse)

Method Details

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<SubscribeToTopicResponse,EventStreamJsonMessage>

Returns:

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

getResponse

public CompletableFuture<SubscribeToTopicResponse> getResponse()

Description copied from interface: StreamResponse

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

Specified by:

getResponse in interface StreamResponse<SubscribeToTopicResponse,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<SubscribeToTopicResponse,EventStreamJsonMessage>

Returns:

True if the stream is closed