Package software.amazon.awssdk.eventstreamrpc

Class EventStreamRPCClient

java.lang.Object

software.amazon.awssdk.eventstreamrpc.EventStreamRPCClient

Direct Known Subclasses:

GreengrassCoreIPCClient

public class EventStreamRPCClient
extends Object

Not sure how public we need to make this class

Constructor Summary

Constructors

Constructor	Description
EventStreamRPCClient(EventStreamRPCConnection connection)	Creates a new EventStreamRPCClient

Method Summary

Modifier and Type	Method	Description
<ReqType extends EventStreamJsonMessage,RespType extends EventStreamJsonMessage,StrReqType extends EventStreamJsonMessage,StrRespType extends EventStreamJsonMessage> OperationResponse<RespType,StrReqType>	doOperationInvoke(OperationModelContext<ReqType,RespType,StrReqType,StrRespType> operationModelContext, ReqType request, Optional<StreamResponseHandler<StrRespType>> streamResponseHandler)	Work horse of all operations, streaming or otherwise.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamRPCClient

public EventStreamRPCClient(EventStreamRPCConnection connection)

Creates a new EventStreamRPCClient

Parameters:

connection - The connection for the EventStreamRPCClient to use

Method Detail

doOperationInvoke

public <ReqType extends EventStreamJsonMessage,RespType extends EventStreamJsonMessage,StrReqType extends EventStreamJsonMessage,StrRespType extends EventStreamJsonMessage> OperationResponse<RespType,StrReqType> doOperationInvoke(OperationModelContext<ReqType,RespType,StrReqType,StrRespType> operationModelContext,
                                                                                                                                                                                                                                                              ReqType request,
                                                                                                                                                                                                                                                              Optional<StreamResponseHandler<StrRespType>> streamResponseHandler)

Work horse of all operations, streaming or otherwise.

Type Parameters:

ReqType - The request type

RespType - The response type

StrReqType - The streaming request type

StrRespType - The streaming response type

Parameters:

operationModelContext - The operation context

request - The request

streamResponseHandler - The streaming handler

Returns:

The operation result