/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/ |
D | ServerConnection.java | 57 …public CompletableFuture<Void> sendProtocolMessage(final List<Header> headers, final byte[] payloa… in sendProtocolMessage() method in ServerConnection 64 … sendProtocolMessage(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
|
D | ClientConnection.java | 58 …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
|
D | OperationRoutingServerConnectionHandler.java | 39 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/ |
D | EventStreamClientConnectionTest.java | 138 …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()
|
D | ServerListenerTest.java | 346 …connection.sendProtocolMessage(null, null, acceptResponseType, responseMessageFlag).whenComplete((… in testContinuationMessageHandling()
|