Searched refs:onContinuationMessage (Results 1 – 9 of 9) sorted by relevance
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/ |
| D | ClientConnectionContinuationHandler.java | 24 protected abstract void onContinuationMessage(final List<Header> headers, in onContinuationMessage() method in ClientConnectionContinuationHandler
41 … onContinuationMessage(headers, payload, MessageType.fromEnumValue(messageType), messageFlags); in onContinuationMessageShim()
|
| D | ServerConnectionContinuationHandler.java | 40 protected abstract void onContinuationMessage(final List<Header> headers, in onContinuationMessage() method in ServerConnectionContinuationHandler
53 … onContinuationMessage(headers, payload, MessageType.fromEnumValue(messageType), messageFlags); in onContinuationMessageShim()
|
| D | OperationRoutingServerConnectionHandler.java | 97 …protected void onContinuationMessage(List<Header> headers, byte[] payload, MessageType messageType… in onIncomingStream() method
|
| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | EventStreamClientConnectionTest.java | 387 …protected void onContinuationMessage(List<Header> headers, byte[] payload, MessageType messageType… in testContinuationMessageHandling()
446 …protected void onContinuationMessage(List<Header> headers, byte[] payload, MessageType messageType… in testContinuationMessageHandling()
539 …protected void onContinuationMessage(List<Header> headers, byte[] payload, MessageType messageType… in testContinuationMessageWithExtraHeadersHandling()
602 …protected void onContinuationMessage(List<Header> headers, byte[] payload, MessageType messageType… in testContinuationMessageWithExtraHeadersHandling()
|
| D | ServerListenerTest.java | 372 …protected void onContinuationMessage(List<Header> headers, byte[] payload, MessageType messageType… in testContinuationMessageHandling()
|
| /external/aws-crt-java/src/native/ |
| D | java_class_ids.h | 280 jmethodID onContinuationMessage; member
294 jmethodID onContinuationMessage; member
|
| D | event_stream_rpc_client.c | 473 event_stream_client_continuation_handler_properties.onContinuationMessage, in s_stream_continuation()
|
| D | java_class_ids.c | 626 event_stream_server_continuation_handler_properties.onContinuationMessage = in s_cache_event_stream_server_continuation_handler_properties()
628 AWS_FATAL_ASSERT(event_stream_server_continuation_handler_properties.onContinuationMessage); in s_cache_event_stream_server_continuation_handler_properties()
657 event_stream_client_continuation_handler_properties.onContinuationMessage = in s_cache_event_stream_client_continuation_handler_properties()
659 AWS_FATAL_ASSERT(event_stream_client_continuation_handler_properties.onContinuationMessage); in s_cache_event_stream_client_continuation_handler_properties()
|
| D | event_stream_rpc_server.c | 155 event_stream_server_continuation_handler_properties.onContinuationMessage, in s_stream_continuation_fn()
|