Home
last modified time | relevance | path

Searched defs:subscribe (Results 1 – 25 of 125) sorted by relevance

12345

/external/perfetto/ui/src/base/
Dstore.ts103 subscribe(callback: Callback<T>): Disposable; method
153 subscribe(callback: Callback<T>): Disposable { method in RootStore
263 subscribe(callback: Callback<T>): Disposable { method in SubStore
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DMigration.kt155 public fun <T> Flow<T>.subscribe(): Unit = noImpl() in <lambda>() method
164 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit): Unit = noImpl() in <lambda>() method
173 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit, onError: suspend (Throwable) -> Unit… in <lambda>() method
/external/aws-sdk-java-v2/test/ruleset-testing-core/src/main/java/software/amazon/awssdk/core/rules/testing/util/
DEmptyPublisher.java24 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in EmptyPublisher
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/
DEmptyPublisher.java36 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in EmptyPublisher
DAsyncRequestBody.java96 public void subscribe(Subscriber<? super ByteBuffer> s) { in fromPublisher() method
DResponsePublisher.java52 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponsePublisher
/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/
DS3MetaRequestPauseObservable.java39 public void subscribe(S3MetaRequest request) { in subscribe() method in S3MetaRequestPauseObservable
DCrtContentLengthOnlyAsyncFileRequestBody.java40 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in CrtContentLengthOnlyAsyncFileRequestBody
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/
DDelegateStreamedHttpRequest.java43 public void subscribe(Subscriber<? super HttpContent> subscriber) { in subscribe() method in DelegateStreamedHttpRequest
DDelegateStreamedHttpResponse.java43 public void subscribe(Subscriber<? super HttpContent> subscriber) { in subscribe() method in DelegateStreamedHttpResponse
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/util/
DPublisherProbe.java41 public void subscribe(Subscriber<? super T> s) { in subscribe() method in PublisherProbe
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
DResponseHandler.java293 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponseHandler.PublisherAdapter
434 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponseHandler.FullResponseContentPublisher
494 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponseHandler.DataCountingPublisher
/external/aws-sdk-java-v2/core/http-auth-aws/src/main/java/software/amazon/awssdk/http/auth/aws/internal/signer/io/
DInMemoryPublisher.java43 public void subscribe(Subscriber<? super ByteBuffer> s) { in subscribe() method in InMemoryPublisher
/external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/
DSdkTestHttpContentPublisher.java21 public void subscribe(Subscriber<? super ByteBuffer> s) { in subscribe() method in SdkTestHttpContentPublisher
DEmptyPublisher.java11 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in EmptyPublisher
/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/crt/
DS3CrtRequestBodyStreamAdapterTest.java67 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in requestBody() method in S3CrtRequestBodyStreamAdapterTest
/external/aws-sdk-java-v2/utils/src/main/java/software/amazon/awssdk/utils/async/
DInputStreamConsumingPublisher.java84 public void subscribe(Subscriber<? super ByteBuffer> s) { in subscribe() method in InputStreamConsumingPublisher
/external/aws-sdk-java-v2/test/http-client-tests/src/main/java/software/amazon/awssdk/http/
DEmptyPublisher.java26 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in EmptyPublisher
/external/aws-sdk-java-v2/core/sdk-core/src/test/java/utils/
DFakePublisher.java26 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in FakePublisher
DFakeSdkPublisher.java26 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in FakeSdkPublisher
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/
DNettyNioAsyncHttpClientTestUtils.java78 public void subscribe(Subscriber<? super ByteBuffer> s) { in createProvider() method in NettyNioAsyncHttpClientTestUtils
DSdkTestHttpContentPublisher.java23 public void subscribe(Subscriber<? super ByteBuffer> s) { in subscribe() method in SdkTestHttpContentPublisher
/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/chunkedencoding/
DTransferEncodingChunkedFunctionalTests.java102 public void subscribe(Subscriber<? super ByteBuffer> s) { in customAsyncRequestBodyWithoutContentLength() method in TransferEncodingChunkedFunctionalTests
/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/
DCompressionAsyncRequestBodyTckTest.java76 public void subscribe(Subscriber<? super ByteBuffer> s) { in customAsyncRequestBodyFromFileWithoutContentLength() method in CompressionAsyncRequestBodyTckTest
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/async/
DSimpleHttpContentPublisher.java51 public void subscribe(Subscriber<? super ByteBuffer> s) { in subscribe() method in SimpleHttpContentPublisher

12345