Home
last modified time | relevance | path

Searched refs:sendProtocolMessage (Results 1 – 5 of 5) sorted by relevance

/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/
DServerConnection.java57 …public CompletableFuture<Void> sendProtocolMessage(final List<Header> headers, final byte[] payloa… in sendProtocolMessage() method in ServerConnection
64sendProtocolMessage(headers, payload, messageType, messageFlags, new MessageFlushCallback() { in sendProtocolMessage()
87 public void sendProtocolMessage(final List<Header> headers, final byte[] payload, in sendProtocolMessage() method in ServerConnection
94 …int result = sendProtocolMessage(getNativeHandle(), headersBuf, payload, messageType.getEnumValue(… in sendProtocolMessage()
125 …private static native int sendProtocolMessage(long connectionPtr, byte[] serialized_headers, byte[… in sendProtocolMessage() method in ServerConnection
DClientConnection.java58 …public CompletableFuture<Void> sendProtocolMessage(final List<Header> headers, final byte[] payloa… in sendProtocolMessage() method in ClientConnection
66 sendProtocolMessage(headers, payload, messageType, messageFlags, errorCode -> { in sendProtocolMessage()
87 public void sendProtocolMessage(final List<Header> headers, final byte[] payload, in sendProtocolMessage() method in ClientConnection
95 …int result = sendProtocolMessage(getNativeHandle(), headersBuf, payload, messageType.getEnumValue(… in sendProtocolMessage()
205 …private static native int sendProtocolMessage(long connectionPtr, byte[] serialized_headers, byte[… in sendProtocolMessage() method in ClientConnection
DOperationRoutingServerConnectionHandler.java39 connection.sendProtocolMessage(null, null, responseMessageType, responseMessageFlag); in onProtocolMessage()
53 …CompletableFuture<Void> voidCompletableFuture = connection.sendProtocolMessage(responseHeaders, re… in onProtocolMessage()
69 connection.sendProtocolMessage(null, null, acceptResponseType, responseMessageFlag); in onConnectRequest()
/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/
DEventStreamClientConnectionTest.java138 …serverConnection.sendProtocolMessage(null, responseMessage, MessageType.ConnectAck, MessageFlags.C… in testConnectionProtocolMessageHandling()
188 clientConnectionArray[0].sendProtocolMessage(null, connectPayload, MessageType.Connect, 0); in testConnectionProtocolMessageHandling()
253 …serverConnection.sendProtocolMessage(respHeaders, responseMessage, MessageType.ConnectAck, Message… in testConnectionProtocolMessageWithExtraHeadersHandling()
312 …clientConnectionArray[0].sendProtocolMessage(clientHeaders, connectPayload, MessageType.Connect, 0… in testConnectionProtocolMessageWithExtraHeadersHandling()
378 … connection.sendProtocolMessage(null, null, acceptResponseType, responseMessageFlag); in testContinuationMessageHandling()
440 clientConnectionArray[0].sendProtocolMessage(null, connectPayload, MessageType.Connect, 0); in testContinuationMessageHandling()
530 … connection.sendProtocolMessage(null, null, acceptResponseType, responseMessageFlag); in testContinuationMessageWithExtraHeadersHandling()
596 clientConnectionArray[0].sendProtocolMessage(null, connectPayload, MessageType.Connect, 0); in testContinuationMessageWithExtraHeadersHandling()
DServerListenerTest.java346 …connection.sendProtocolMessage(null, null, acceptResponseType, responseMessageFlag).whenComplete((… in testContinuationMessageHandling()