software.amazon.awssdk.eventstreamrpc

Class EventStreamRPCConnection

java.lang.Object

software.amazon.awssdk.eventstreamrpc.EventStreamRPCConnection

All Implemented Interfaces:

AutoCloseable

public class EventStreamRPCConnection
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	EventStreamRPCConnection.LifecycleHandler Lifecycle handler is how a client can react and respond to connectivity interruptions.

Constructor Summary

Constructors

Constructor and Description
EventStreamRPCConnection(EventStreamRPCConnectionConfig config)

Method Summary

Modifier and Type	Method and Description
void	close()
CompletableFuture<Void>	connect(EventStreamRPCConnection.LifecycleHandler lifecycleHandler) Connects to the event stream RPC server asynchronously
void	disconnect()
software.amazon.awssdk.crt.eventstream.ClientConnectionContinuation	newStream(software.amazon.awssdk.crt.eventstream.ClientConnectionContinuationHandler continuationHandler)
CompletableFuture<Void>	sendPing(Optional<MessageAmendInfo> pingData) Interface to send ping.
CompletableFuture<Void>	sendPingResponse(Optional<MessageAmendInfo> pingResponseData) Interface to send pingResponse.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamRPCConnection

public EventStreamRPCConnection(EventStreamRPCConnectionConfig config)

Method Detail

connect

public CompletableFuture<Void> connect(EventStreamRPCConnection.LifecycleHandler lifecycleHandler)

Connects to the event stream RPC server asynchronously

Returns:

newStream

public software.amazon.awssdk.crt.eventstream.ClientConnectionContinuation newStream(software.amazon.awssdk.crt.eventstream.ClientConnectionContinuationHandler continuationHandler)

disconnect

public void disconnect()

sendPing

public CompletableFuture<Void> sendPing(Optional<MessageAmendInfo> pingData)

Interface to send ping. Optional MessageAmendInfo will use the headers and payload for the ping message verbatim. Should trigger a pong response and server copies back

Parameters:

pingData -

Returns:

sendPingResponse

public CompletableFuture<Void> sendPingResponse(Optional<MessageAmendInfo> pingResponseData)

Interface to send pingResponse. Optional MessageAmendInfo will use the headers and payload for the ping message verbatim. Should trigger a pong response and server copies back

Parameters:

pingResponseData -

Returns:

close

public void close()

Specified by:

close in interface AutoCloseable