Home
last modified time | relevance | path

Searched defs:onStream (Results 1 – 25 of 35) sorted by relevance

12

/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/util/
DAsyncResponseHandlerTestUtils.java78 public void onStream(Publisher<ByteBuffer> stream) { in onStream() method in AsyncResponseHandlerTestUtils.NoOpResponseHandler
124 public void onStream(Publisher<ByteBuffer> stream) { in onStream() method
/external/aws-sdk-java-v2/http-client-spi/src/main/java/software/amazon/awssdk/http/async/
DSdkAsyncHttpResponseHandler.java43 void onStream(Publisher<ByteBuffer> stream); in onStream() method
DSdkHttpResponseHandler.java49 void onStream(Publisher<ByteBuffer> publisher); in onStream() method
/external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/s3/crt/
DTestResponseTransformer.java42 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in TestResponseTransformer
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/
DPublisherAsyncResponseTransformer.java52 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in PublisherAsyncResponseTransformer
DInputStreamResponseTransformer.java52 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in InputStreamResponseTransformer
DByteArrayAsyncResponseTransformer.java59 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in ByteArrayAsyncResponseTransformer
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/async/
DFilterTransformingAsyncHttpResponseHandler.java48 public void onStream(Publisher<ByteBuffer> stream) { in onStream() method in FilterTransformingAsyncHttpResponseHandler
DAsyncStreamingResponseHandler.java62 public void onStream(Publisher<ByteBuffer> publisher) { in onStream() method in AsyncStreamingResponseHandler
DAsyncResponseHandler.java70 public void onStream(Publisher<ByteBuffer> publisher) { in onStream() method in AsyncResponseHandler
DAsyncAfterTransmissionInterceptorCallingResponseHandler.java76 public void onStream(Publisher<ByteBuffer> publisher) { in onStream() method in AsyncAfterTransmissionInterceptorCallingResponseHandler
DCombinedResponseAsyncHttpResponseHandler.java75 public void onStream(Publisher<ByteBuffer> publisher) { in onStream() method in CombinedResponseAsyncHttpResponseHandler
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/
DRecordingResponseHandler.java49 public void onStream(Publisher<ByteBuffer> publisher) { in onStream() method in RecordingResponseHandler
/external/aws-sdk-java-v2/test/http-client-tests/src/main/java/software/amazon/awssdk/http/
DRecordingResponseHandler.java41 public void onStream(Publisher<ByteBuffer> publisher) { in onStream() method in RecordingResponseHandler
/external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/internal/
DCrtResponseHandlerTest.java92 public void onStream(Publisher<ByteBuffer> stream) { in onStream() method in CrtResponseHandlerTest.TestAsyncHttpResponseHandler
/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/
DAsyncResponseTransformerTest.java131 public void onStream(SdkPublisher publisher) { in onStream() method in AsyncResponseTransformerTest.TestAsyncResponseTransformer
DAsyncFaultTest.java105 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in AsyncFaultTest.CancelSubscriptionTransformer
/external/aws-sdk-java-v2/test/s3-benchmarks/src/main/java/software/amazon/awssdk/s3benchmarks/
DNoOpResponseTransformer.java43 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in NoOpResponseTransformer
/external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/s3/
DAsyncGetObjectFaultIntegrationTest.java122 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/
DIdempotentAsyncResponseHandler.java107 public void onStream(Publisher<ByteBuffer> stream) { in onStream() method in IdempotentAsyncResponseHandler
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/
DAsyncResponseTransformer.java106 void onStream(SdkPublisher<ByteBuffer> publisher); in onStream() method
/external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/eventstream/
DRestEventStreamAsyncResponseTransformer.java60 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in RestEventStreamAsyncResponseTransformer
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/listener/
DAsyncResponseTransformerListener.java91 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in AsyncResponseTransformerListener.NotifyingAsyncResponseTransformer
/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/timeout/async/
DAsyncApiCallAttemptsTimeoutTest.java169 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method
/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/client/handler/
DAsyncClientHandlerTransformerVerificationTest.java251 public void onStream(SdkPublisher<ByteBuffer> publisher) { in onStream() method in AsyncClientHandlerTransformerVerificationTest.TestTransformer

12