| /external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| D | SimplePublisherTest.java | 53 SimplePublisher<Integer> publisher = new SimplePublisher<>(); in immediateSuccessWorks() local
55 publisher.subscribe(subscriber); in immediateSuccessWorks()
56 publisher.complete(); in immediateSuccessWorks()
66 SimplePublisher<Integer> publisher = new SimplePublisher<>(); in immediateFailureWorks() local
68 publisher.subscribe(subscriber); in immediateFailureWorks()
69 publisher.error(error); in immediateFailureWorks()
81 SimplePublisher<Integer> publisher = new SimplePublisher<>(); in writeAfterCompleteFails() local
82 publisher.subscribe(new StoringSubscriber<>(1)); in writeAfterCompleteFails()
83 publisher.complete(); in writeAfterCompleteFails()
84 assertThat(publisher.send(5)).isCompletedExceptionally(); in writeAfterCompleteFails()
[all …]
|
| D | OutputStreamPublisherTest.java | 36 private OutputStreamPublisher publisher; field in OutputStreamPublisherTest
42 publisher = new OutputStreamPublisher(); in setup()
47 publisher.subscribe(storingSubscriber); in oneByteWritesAreBuffered()
48 publisher.write(0); in oneByteWritesAreBuffered()
54 publisher.subscribe(storingSubscriber); in oneByteWritesAreFlushedEventually()
56 publisher.write(0); in oneByteWritesAreFlushedEventually()
65 publisher.subscribe(storingSubscriber); in flushDrainsBufferedBytes()
66 publisher.write(0); in flushDrainsBufferedBytes()
67 publisher.flush(); in flushDrainsBufferedBytes()
75 publisher.subscribe(storingSubscriber); in emptyFlushDoesNothing()
[all …]
|
| D | InputStreamConsumingPublisherTest.java | 39 private InputStreamConsumingPublisher publisher; field in InputStreamConsumingPublisherTest
44 this.publisher = new InputStreamConsumingPublisher(); in setup()
49 EXECUTOR.submit(() -> publisher.doBlockingWrite(streamOfLength(0))); in subscribeAfterWrite_completes()
51 publisher.subscribe(subscriber); in subscribeAfterWrite_completes()
58 publisher.subscribe(subscriber); in zeroKb_completes()
60 assertThat(publisher.doBlockingWrite(streamOfLength(0))).isEqualTo(0); in zeroKb_completes()
66 publisher.subscribe(subscriber); in oneKb_writesAndCompletes()
68 assertThat(publisher.doBlockingWrite(streamOfLength(1024))).isEqualTo(1024); in oneKb_writesAndCompletes()
75 publisher.subscribe(subscriber); in bytesAreDeliveredInOrder()
77 assertThat(publisher.doBlockingWrite(streamWithAllBytesInOrder())).isEqualTo(256); in bytesAreDeliveredInOrder()
[all …]
|
| D | InputStreamSubscriberTest.java | 47 private SimplePublisher<ByteBuffer> publisher; field in InputStreamSubscriberTest
52 publisher = new SimplePublisher<>(); in setup()
58 publisher.subscribe(subscriber); in onComplete_returnsEndOfStream_onRead()
59 publisher.complete(); in onComplete_returnsEndOfStream_onRead()
69 publisher.subscribe(subscriber); in onError_throws_onRead()
70 publisher.error(exception); in onError_throws_onRead()
78 publisher.subscribe(subscriber); in onComplete_afterOnNext_returnsEndOfStream()
79 publisher.send(byteBufferOfLength(1)); in onComplete_afterOnNext_returnsEndOfStream()
80 publisher.complete(); in onComplete_afterOnNext_returnsEndOfStream()
87 publisher.subscribe(subscriber); in onComplete_afterEmptyOnNext_returnsEndOfStream()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/ |
| D | README.md | 9 …x.coroutines.reactive.publish] | `Publisher` | [ProducerScope] | Cold reac…
15 | [Publisher.asFlow] | `Flow` | Converts the given publisher to a flow
16 | [Flow.asPublisher] | `Publisher` | Converts the given flow to a TCK-compliant publisher
25 | [Publisher.awaitFirst][org.reactivestreams.Publisher.awaitFirst] | Returns the first value from t…
26 | [Publisher.awaitFirstOrDefault][org.reactivestreams.Publisher.awaitFirstOrDefault] | Returns the …
27 | [Publisher.awaitFirstOrElse][org.reactivestreams.Publisher.awaitFirstOrElse] | Returns the first …
28 | [Publisher.awaitFirstOrNull][org.reactivestreams.Publisher.awaitFirstOrNull] | Returns the first …
29 | [Publisher.awaitLast][org.reactivestreams.Publisher.awaitFirst] | Returns the last value from the…
30 | [Publisher.awaitSingle][org.reactivestreams.Publisher.awaitSingle] | Returns the single value fro…
46 [Publisher.asFlow]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactive/kotli…
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/ |
| D | kotlinx-coroutines-reactive.api | 2 …public static final fun awaitFirst (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation…
3 …public static final fun awaitFirstOrDefault (Lorg/reactivestreams/Publisher;Ljava/lang/Object;Lkot…
4 …public static final fun awaitFirstOrElse (Lorg/reactivestreams/Publisher;Lkotlin/jvm/functions/Fun…
5 …public static final fun awaitFirstOrNull (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Contin…
6 …public static final fun awaitLast (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation;…
7 …public static final fun awaitSingle (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuatio…
8 …public static final synthetic fun awaitSingleOrDefault (Lorg/reactivestreams/Publisher;Ljava/lang/…
9 …public static final synthetic fun awaitSingleOrElse (Lorg/reactivestreams/Publisher;Lkotlin/jvm/fu…
10 …public static final synthetic fun awaitSingleOrNull (Lorg/reactivestreams/Publisher;Lkotlin/corout…
14 …public static final fun collect (Lorg/reactivestreams/Publisher;Lkotlin/jvm/functions/Function1;Lk…
[all …]
|
| /external/ot-br-posix/tests/mdns/ |
| D | main.cpp | 53 static Publisher *sPublisher = nullptr;
109 Publisher::TxtData txtData; in PublishSingleServiceWithCustomHost()
110 Publisher::TxtList txtList{ in PublishSingleServiceWithCustomHost()
123 Publisher::EncodeTxtData(txtList, txtData); in PublishSingleServiceWithCustomHost()
127 …sPublisher->PublishService(hostName, "SingleService", "_meshcop._udp", Publisher::SubTypeList{}, 1… in PublishSingleServiceWithCustomHost()
136 Publisher::TxtData txtData; in PublishSingleServiceWithKeyAfterwards()
149 …hostName, "SingleService", "_meshcop._udp", Publisher::SubTypeList{}, 12345, txtData, [](otbrError… in PublishSingleServiceWithKeyAfterwards()
167 Publisher::TxtData txtData; in PublishMultipleServicesWithCustomHost()
168 Publisher::TxtList txtList{ in PublishMultipleServicesWithCustomHost()
181 Publisher::EncodeTxtData(txtList, txtData); in PublishMultipleServicesWithCustomHost()
[all …]
|
| D | test_subscribe.cpp | 105 Publisher::ResultCallback NoOpCallback(void) in NoOpCallback()
110 std::map<std::string, std::vector<uint8_t>> AsTxtMap(const Publisher::TxtData &aTxtData) in AsTxtMap()
112 Publisher::TxtList txtList; in AsTxtMap()
115 Publisher::DecodeTxtData(txtList, aTxtData.data(), aTxtData.size()); in AsTxtMap()
124 Publisher::TxtList sTxtList1{{"a", "1"}, {"b", "2"}};
125 Publisher::TxtData sTxtData1;
138 SuccessOrDie(Publisher::EncodeTxtData(sTxtList1, sTxtData1), ""); in SetUp()
141 std::unique_ptr<Publisher> CreatePublisher(void) in CreatePublisher()
144 …std::unique_ptr<Publisher> publisher{Publisher::Create([&publisher, &ready](Mdns::Publisher::State… in CreatePublisher() local
145 if (aState == Publisher::State::kReady) in CreatePublisher()
[all …]
|
| /external/google-cloud-java/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/ |
| D | PublisherModelName.java | 33 PathTemplate.createWithoutUrlEncoding("publishers/{publisher}/models/{model}");
35 private final String publisher; field in PublisherModelName
40 publisher = null; in PublisherModelName()
45 publisher = Preconditions.checkNotNull(builder.getPublisher()); in PublisherModelName()
50 return publisher; in getPublisher()
65 public static PublisherModelName of(String publisher, String model) { in of() argument
66 return newBuilder().setPublisher(publisher).setModel(model).build(); in of()
69 public static String format(String publisher, String model) { in format() argument
70 return newBuilder().setPublisher(publisher).setModel(model).build().toString(); in format()
80 return of(matchMap.get("publisher"), matchMap.get("model")); in parse()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/ |
| D | Await.kt | 13 …* Awaits the first value from the given publisher without blocking the thread and returns the resu…
14 * the publisher has produced an error, throws the corresponding exception.
20 * @throws NoSuchElementException if the publisher does not emit any value
22 public suspend fun <T> Flow.Publisher<T>.awaitFirst(): T =
26 …* Awaits the first value from the given publisher, or returns the [default] value if none is emitt…
27 …* the thread, and returns the resulting value, or, if this publisher has produced an error, throws…
34 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrDefault(default: T): T =
38 …* Awaits the first value from the given publisher, or returns `null` if none is emitted, without b…
39 …* and returns the resulting value, or, if this publisher has produced an error, throws the corresp…
45 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrNull(): T? =
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/ |
| D | EnvelopeWrappedSdkPublisher.java | 19 import org.reactivestreams.Publisher;
26 …* Publisher implementation that wraps the content of another publisher in an envelope with an opti…
28 …* wrapped publisher, and the suffix content will be published when the wrapped publisher signals c…
30 …* The envelope prefix will not be published until the wrapped publisher publishes something or is …
31 * The envelope suffix will not be published until the wrapped publisher is completed.
37 * the wrapped publisher. Example usage:
39 …* Publisher<String> wrappedPublisher = ContentEnvelopeWrappingPublisher.of(publisher, "S", "E",…
41 …* If publisher publishes a single string "1", wrappedPublisher will publish "S1" (prepending the e…
42 …* publisher then publishes a second string "2", wrappedPublisher will then publish "2" (no added c…
43 * publisher then completes, wrappedPublisher will then publish "E" and then complete.
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Await.kt | 8 import org.reactivestreams.Publisher in <lambda>()
15 …* Awaits the first value from the given publisher without blocking the thread and returns the resu… in <lambda>()
16 * the publisher has produced an error, throws the corresponding exception. in <lambda>()
22 * @throws NoSuchElementException if the publisher does not emit any value in <lambda>()
24 public suspend fun <T> Publisher<T>.awaitFirst(): T = awaitOne(Mode.FIRST) in <lambda>()
27 …* Awaits the first value from the given publisher, or returns the [default] value if none is emitt… in <lambda>()
28 …* the thread, and returns the resulting value, or, if this publisher has produced an error, throws… in <lambda>()
35 public suspend fun <T> Publisher<T>.awaitFirstOrDefault(default: T): T = awaitOne(Mode.FIRST_OR_DEF… in <lambda>()
38 …* Awaits the first value from the given publisher, or returns `null` if none is emitted, without b… in <lambda>()
39 …* and returns the resulting value, or, if this publisher has produced an error, throws the corresp… in <lambda>()
[all …]
|
| /external/ot-br-posix/src/mdns/ |
| D | mdns.cpp | 31 * This file includes implementation of mDNS publisher.
52 void Publisher::PublishService(const std::string &aHostName, in PublishService()
71 void Publisher::PublishHost(const std::string &aName, const AddressList &aAddresses, ResultCallback… in PublishHost()
84 void Publisher::PublishKey(const std::string &aName, const KeyData &aKeyData, ResultCallback &&aCal… in PublishKey()
97 void Publisher::OnServiceResolveFailed(std::string aType, std::string aInstanceName, int32_t aError… in OnServiceResolveFailed()
104 void Publisher::OnHostResolveFailed(std::string aHostName, int32_t aErrorCode) in OnHostResolveFailed()
111 otbrError Publisher::EncodeTxtData(const TxtList &aTxtList, std::vector<uint8_t> &aTxtData) in EncodeTxtData()
147 otbrError Publisher::DecodeTxtData(Publisher::TxtList &aTxtList, const uint8_t *aTxtData, uint16_t … in DecodeTxtData()
190 void Publisher::RemoveSubscriptionCallbacks(uint64_t aSubscriberId) in RemoveSubscriptionCallbacks()
196 uint64_t Publisher::AddSubscriptionCallbacks(Publisher::DiscoveredServiceInstanceCallback aInstance… in AddSubscriptionCallbacks()
[all …]
|
| /external/google-cloud-java/java-analyticshub/proto-google-cloud-analyticshub-v1/src/main/java/com/google/cloud/bigquery/analyticshub/v1/ |
| D | Publisher.java | 25 * Contains details of the listing publisher.
28 * Protobuf type {@code google.cloud.bigquery.analyticshub.v1.Publisher}
30 public final class Publisher extends com.google.protobuf.GeneratedMessageV3 class
32 // @@protoc_insertion_point(message_implements:google.cloud.bigquery.analyticshub.v1.Publisher)
35 // Use Publisher.newBuilder() to construct.
36 private Publisher(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Publisher() method in Publisher
40 private Publisher() { in Publisher() method in Publisher
48 return new Publisher(); in newInstance()
67 com.google.cloud.bigquery.analyticshub.v1.Publisher.class, in internalGetFieldAccessorTable()
68 com.google.cloud.bigquery.analyticshub.v1.Publisher.Builder.class); in internalGetFieldAccessorTable()
[all …]
|
| /external/google-cloud-java/java-bigquery-data-exchange/proto-google-cloud-bigquery-data-exchange-v1beta1/src/main/java/com/google/cloud/bigquery/dataexchange/v1beta1/ |
| D | Publisher.java | 25 * Contains details of the listing publisher.
28 * Protobuf type {@code google.cloud.bigquery.dataexchange.v1beta1.Publisher}
30 public final class Publisher extends com.google.protobuf.GeneratedMessageV3 class
32 …/ @@protoc_insertion_point(message_implements:google.cloud.bigquery.dataexchange.v1beta1.Publisher)
35 // Use Publisher.newBuilder() to construct.
36 private Publisher(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Publisher() method in Publisher
40 private Publisher() { in Publisher() method in Publisher
48 return new Publisher(); in newInstance()
67 com.google.cloud.bigquery.dataexchange.v1beta1.Publisher.class, in internalGetFieldAccessorTable()
68 com.google.cloud.bigquery.dataexchange.v1beta1.Publisher.Builder.class); in internalGetFieldAccessorTable()
[all …]
|
| /external/python/google-api-python-client/docs/dyn/ |
| D | adexchangebuyer_v1_4.pubprofiles.html | 82 <p class="firstline">Gets the requested publisher profile(s) by publisher accountId.</p>
91 <pre>Gets the requested publisher profile(s) by publisher accountId.
94 accountId: integer, The accountId of the publisher to get profiles for. (required)
100 "profiles": [ # Profiles for the requested publisher
102 "audience": "A String", # Publisher provided info on its audience.
104 "directContact": "A String", # Direct contact for the publisher profile.
105 …"exchange": "A String", # Exchange where this publisher profile is from. E.g. …
107 "googlePlusLink": "A String", # Link to publisher's Google+ page.
108 … False, # True, if this is the parent profile, which represents all domains owned by the publisher.
111 "logoUrl": "A String", # The url to the logo for the publisher.
[all …]
|
| D | adexchangebuyer2_v2beta1.accounts.publisherProfiles.html | 82 <p class="firstline">Gets the requested publisher profile by id.</p>
85 <p class="firstline">List all publisher profiles visible to the buyer</p>
97 <pre>Gets the requested publisher profile by id.
101 publisherProfileId: string, The id for the publisher profile to get. (required)
110 …publisher profile (https://support.google.com/admanager/answer/6035806) in Marketplace. All fields…
111 …"audienceDescription": "A String", # Description on the publisher's audie…
112 …nt explaining what's unique about publisher's business, and why buyers should partner wi…
113 …ormation for direct reservation deals. This is free text entered by the publisher and may include …
114 "displayName": "A String", # Name of the publisher profile.
115 …"domains": [ # The list of domains represented in this publisher profile. Empty if this …
[all …]
|
| D | authorizedbuyersmarketplace_v1.buyers.publisherProfiles.html | 82 <p class="firstline">Gets the requested publisher profile by name.</p>
85 <p class="firstline">Lists publisher profiles</p>
97 <pre>Gets the requested publisher profile by name.
100 …name: string, Required. Name of the publisher profile. Format: `buyers/{buyerId}/publisherProfiles…
109 …{ # The values in the publisher profile are supplied by the publisher. All fields are not filterab…
110 …"audienceDescription": "A String", # Description on the publisher's audie…
111 …ormation for direct reservation deals. This is free text entered by the publisher and may include …
112 …"displayName": "A String", # Display name of the publisher profile. Can be use…
113 …"domains": [ # The list of domains represented in this publisher profile. Empty if this …
116 …created to brand a portion of inventory. One seller has only one parent publisher profile, and can…
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/api/ |
| D | kotlinx-coroutines-reactor.api | 2 …routines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;)Lreactor/core/publisher/Flux;
3 …eceiveChannel;Lkotlin/coroutines/CoroutineContext;ILjava/lang/Object;)Lreactor/core/publisher/Flux;
4 …no (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;)Lreactor/core/publisher/Mono;
5 … asMono (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext;)Lreactor/core/publisher/Mono;
9 …public static final synthetic fun asFlux (Lkotlinx/coroutines/flow/Flow;)Lreactor/core/publisher/F…
13 …(Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lreactor/core/publisher/Flux;
14 …;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lreactor/core/publisher/Flux;
15 …/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lreactor/core/publisher/Flux;
16 …/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lreactor/core/publisher/Flux;
20 …public static final synthetic fun awaitFirst (Lreactor/core/publisher/Mono;Lkotlin/coroutines/Cont…
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/ |
| D | SdkPublisher.java | 24 import org.reactivestreams.Publisher;
41 public interface SdkPublisher<T> extends Publisher<T> {
44 * Adapts a {@link Publisher} to {@link SdkPublisher}.
46 * @param toAdapt {@link Publisher} to adapt.
50 static <T> SdkPublisher<T> adapt(Publisher<T> toAdapt) { in adapt()
56 * publisher to the type specified in the {@link Class}.
60 * @return New publisher, filtered to the given class.
68 * does not change the type of the {@link Publisher}.
71 * @return New publisher, filtered to just the events that match the predicate.
78 …* Perform a mapping on the published events. Returns a new publisher of the mapped events. Typical…
[all …]
|
| /external/openthread/src/core/thread/ |
| D | network_data_publisher.cpp | 31 * This file implements the Network Data Publisher.
55 // Publisher
57 Publisher::Publisher(Instance &aInstance) in Publisher() function in ot::NetworkData::Publisher
80 Error Publisher::PublishOnMeshPrefix(const OnMeshPrefixConfig &aConfig, Requester aRequester) in PublishOnMeshPrefix()
97 Error Publisher::PublishExternalRoute(const ExternalRouteConfig &aConfig, Requester aRequester) in PublishExternalRoute()
102 Error Publisher::ReplacePublishedExternalRoute(const Ip6::Prefix &aPrefix, in ReplacePublishedExternalRoute()
121 bool Publisher::IsPrefixAdded(const Ip6::Prefix &aPrefix) const in IsPrefixAdded()
135 Error Publisher::UnpublishPrefix(const Ip6::Prefix &aPrefix) in UnpublishPrefix()
149 Publisher::PrefixEntry *Publisher::FindOrAllocatePrefixEntry(const Ip6::Prefix &aPrefix, Requester … in FindOrAllocatePrefixEntry()
195 Publisher::PrefixEntry *Publisher::FindMatchingPrefixEntry(const Ip6::Prefix &aPrefix) in FindMatchingPrefixEntry()
[all …]
|
| /external/openthread/src/core/api/ |
| D | netdata_publisher_api.cpp | 31 * This file implements the OpenThread Network Data Publisher API.
49 … AsCoreType(aInstance).Get<NetworkData::Publisher>().PublishDnsSrpServiceAnycast(aSequenceNumber); in otNetDataPublishDnsSrpServiceAnycast()
54 …AsCoreType(aInstance).Get<NetworkData::Publisher>().PublishDnsSrpServiceUnicast(AsCoreType(aAddres… in otNetDataPublishDnsSrpServiceUnicast()
59 AsCoreType(aInstance).Get<NetworkData::Publisher>().PublishDnsSrpServiceUnicast(aPort); in otNetDataPublishDnsSrpServiceUnicastMeshLocalEid()
64 return AsCoreType(aInstance).Get<NetworkData::Publisher>().IsDnsSrpServiceAdded(); in otNetDataIsDnsSrpServiceAdded()
71 … AsCoreType(aInstance).Get<NetworkData::Publisher>().SetDnsSrpServiceCallback(aCallback, aContext); in otNetDataSetDnsSrpServicePublisherCallback()
76 AsCoreType(aInstance).Get<NetworkData::Publisher>().UnpublishDnsSrpService(); in otNetDataUnpublishDnsSrpService()
85 …return AsCoreType(aInstance).Get<NetworkData::Publisher>().PublishOnMeshPrefix(AsCoreType(aConfig), in otNetDataPublishOnMeshPrefix()
86 … NetworkData::Publisher::kFromUser); in otNetDataPublishOnMeshPrefix()
91 …return AsCoreType(aInstance).Get<NetworkData::Publisher>().PublishExternalRoute(AsCoreType(aConfig… in otNetDataPublishExternalRoute()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/api/ |
| D | kotlinx-coroutines-jdk9.api | 2 …public static final fun awaitFirst (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Contin…
3 …public static final fun awaitFirstOrDefault (Ljava/util/concurrent/Flow$Publisher;Ljava/lang/Objec…
4 …public static final fun awaitFirstOrElse (Ljava/util/concurrent/Flow$Publisher;Lkotlin/jvm/functio…
5 …public static final fun awaitFirstOrNull (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/…
6 …public static final fun awaitLast (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continu…
7 …public static final fun awaitSingle (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Conti…
11 …/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Ljava/util/concurrent/Flow$Publisher;
12 …neContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Ljava/util/concurrent/Flow$Publisher;
16 …public static final fun asFlow (Ljava/util/concurrent/Flow$Publisher;)Lkotlinx/coroutines/flow/Flo…
17 … static final fun asPublisher (Lkotlinx/coroutines/flow/Flow;)Ljava/util/concurrent/Flow$Publisher;
[all …]
|
| /external/aws-sdk-java-v2/metric-publishers/cloudwatch-metric-publisher/src/test/java/software/amazon/awssdk/metrics/publishers/cloudwatch/ |
| D | CloudWatchMetricPublisherTest.java | 61 try (CloudWatchMetricPublisher publisher = publisherBuilder.build()) { in noMetricsNoCalls() argument
62 publisher.publish(MetricCollector.create("test").collect()); in noMetricsNoCalls()
69 CloudWatchMetricPublisher publisher = publisherBuilder.build(); in interruptedShutdownStillTerminates() local
71 publisher.close(); in interruptedShutdownStillTerminates()
72 assertThat(publisher.isShutdown()).isTrue(); in interruptedShutdownStillTerminates()
88 try (CloudWatchMetricPublisher publisher = CloudWatchMetricPublisher.builder() in closeWaitsForUploadToComplete() argument
94 publisher.publish(new FixedTimeMetricCollection(collector.collect())); in closeWaitsForUploadToComplete()
101 publisher.publish(MetricCollector.create("test").collect()); in closeWaitsForUploadToComplete()
103 Thread closeThread = new Thread(publisher::close); in closeWaitsForUploadToComplete()
105 assertThat(publisher.isShutdown()).isFalse(); in closeWaitsForUploadToComplete()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/http/async/ |
| D | CombinedResponseAsyncHttpResponseHandlerTest.java | 54 responseHandler.onStream(publisher())) in onStream_invokedWithoutPrepare_shouldThrowException()
73 responseHandler.onStream(publisher())) in onStream_invokedWithoutOnHeaders_shouldThrowException()
84 Flowable<ByteBuffer> publisher = publisher(); in onStream_HeadersFutureCompleteSuccessfully_shouldNotThrowException() local
85 responseHandler.onStream(publisher); in onStream_HeadersFutureCompleteSuccessfully_shouldNotThrowException()
86 verify(successResponseHandler, times(0)).onStream(publisher); in onStream_HeadersFutureCompleteSuccessfully_shouldNotThrowException()
87 verify(errorResponseHandler, times(0)).onStream(publisher); in onStream_HeadersFutureCompleteSuccessfully_shouldNotThrowException()
98 Flowable<ByteBuffer> publisher = publisher(); in successResponse_shouldCompleteHeaderFuture() local
100 responseHandler.onStream(publisher); in successResponse_shouldCompleteHeaderFuture()
102 verify(successResponseHandler).onStream(publisher); in successResponse_shouldCompleteHeaderFuture()
115 Flowable<ByteBuffer> publisher = publisher(); in errorResponse_shouldCompleteHeaderFuture() local
[all …]
|