| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| H A 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 …]
|
| H A 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 …]
|
| H A 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 …]
|
| /aosp_15_r20/external/ot-br-posix/tests/mdns/ |
| H A 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 …]
|
| /aosp_15_r20/external/google-cloud-java/java-analyticshub/proto-google-cloud-analyticshub-v1/src/main/java/com/google/cloud/bigquery/analyticshub/v1/ |
| H A 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 …]
|
| /aosp_15_r20/external/google-cloud-java/java-bigquery-data-exchange/proto-google-cloud-bigquery-data-exchange-v1beta1/src/main/java/com/google/cloud/bigquery/dataexchange/v1beta1/ |
| H A 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 …]
|
| /aosp_15_r20/external/ot-br-posix/src/mdns/ |
| H A 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 …]
|
| /aosp_15_r20/external/openthread/src/core/thread/ |
| H A D | network_data_publisher.cpp | 31 * This file implements the Network Data Publisher.
54 // Publisher
56 Publisher::Publisher(Instance &aInstance) in Publisher() function in ot::NetworkData::Publisher
79 Error Publisher::PublishOnMeshPrefix(const OnMeshPrefixConfig &aConfig, Requester aRequester) in PublishOnMeshPrefix()
96 Error Publisher::PublishExternalRoute(const ExternalRouteConfig &aConfig, Requester aRequester) in PublishExternalRoute()
101 Error Publisher::ReplacePublishedExternalRoute(const Ip6::Prefix &aPrefix, in ReplacePublishedExternalRoute()
120 bool Publisher::IsPrefixAdded(const Ip6::Prefix &aPrefix) const in IsPrefixAdded()
134 Error Publisher::UnpublishPrefix(const Ip6::Prefix &aPrefix) in UnpublishPrefix()
148 Publisher::PrefixEntry *Publisher::FindOrAllocatePrefixEntry(const Ip6::Prefix &aPrefix, Requester … in FindOrAllocatePrefixEntry()
194 Publisher::PrefixEntry *Publisher::FindMatchingPrefixEntry(const Ip6::Prefix &aPrefix) in FindMatchingPrefixEntry()
[all …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| H A D | Await.kt | 4 import org.reactivestreams.Publisher in <lambda>()
11 …* Awaits the first value from the given publisher without blocking the thread and returns the resu… in <lambda>()
12 * the publisher has produced an error, throws the corresponding exception. in <lambda>()
18 * @throws NoSuchElementException if the publisher does not emit any value in <lambda>()
20 public suspend fun <T> Publisher<T>.awaitFirst(): T = awaitOne(Mode.FIRST) in <lambda>()
23 …* Awaits the first value from the given publisher, or returns the [default] value if none is emitt… in <lambda>()
24 …* the thread, and returns the resulting value, or, if this publisher has produced an error, throws… in <lambda>()
31 public suspend fun <T> Publisher<T>.awaitFirstOrDefault(default: T): T = awaitOne(Mode.FIRST_OR_DEF… in <lambda>()
34 …* Awaits the first value from the given publisher, or returns `null` if none is emitted, without b… in <lambda>()
35 …* and returns the resulting value, or, if this publisher has produced an error, throws the corresp… in <lambda>()
[all …]
|
| /aosp_15_r20/external/ot-br-posix/tests/gtest/ |
| H A D | test_mdns_subscribe.cpp | 89 Publisher::ResultCallback NoOpCallback(void) in NoOpCallback()
94 std::map<std::string, std::vector<uint8_t>> AsTxtMap(const Publisher::TxtData &aTxtData) in AsTxtMap()
96 Publisher::TxtList txtList; in AsTxtMap()
99 Publisher::DecodeTxtData(txtList, aTxtData.data(), aTxtData.size()); in AsTxtMap()
108 Publisher::TxtList sTxtList1{{"a", "1"}, {"b", "2"}};
109 Publisher::TxtData sTxtData1;
124 SuccessOrDie(Publisher::EncodeTxtData(sTxtList1, sTxtData1), ""); in MdnsTest()
128 std::unique_ptr<Publisher> CreatePublisher(void) in CreatePublisher()
131 std::unique_ptr<Publisher> publisher{Publisher::Create([&ready](Mdns::Publisher::State aState) { in CreatePublisher() local
132 if (aState == Publisher::State::kReady) in CreatePublisher()
[all …]
|
| /aosp_15_r20/external/python/google-api-python-client/docs/dyn/ |
| 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 …]
|
| 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 | realtimebidding_v1.bidders.pretargetingConfigs.html | 156 …uot;: { # Generic targeting with string values used in app, website and publisher targeting. # Tar…
207 …publisher targeting. # Targeting on a subset of publisher inventory. Publishers can either be targ…
222 …ion as defined in https://developers.google.com/authorized-buyers/rtb/downloads/publisher-verticals
230 …uot;: { # Generic targeting with string values used in app, website and publisher targeting. # Tar…
276 …uot;: { # Generic targeting with string values used in app, website and publisher targeting. # Tar…
327 …publisher targeting. # Targeting on a subset of publisher inventory. Publishers can either be targ…
342 …ion as defined in https://developers.google.com/authorized-buyers/rtb/downloads/publisher-verticals
350 …uot;: { # Generic targeting with string values used in app, website and publisher targeting. # Tar…
369 …publisher IDs to target in the pretargeting configuration. These values will be added to the list …
372 …he targeting mode that should be applied to the list of publisher IDs. If are existing publisher I…
[all …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/ |
| H A 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 …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/ |
| H A 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 …]
|
| /aosp_15_r20/frameworks/native/libs/bufferstreams/rust/src/ |
| H A D | lib.rs | 39 /// * The total number of on_next´s signalled by a Publisher to a Subscriber
42 /// * A Publisher MAY signal fewer on_next than requested and terminate the
46 /// * If a Publisher fails it MUST signal an on_error.
47 /// * If a Publisher terminates successfully (finite stream) it MUST signal an
49 /// * If a Publisher signals either on_error or on_complete on a Subscriber,
55 /// * A Publisher MAY support multiple Subscribers and decides whether each
58 /// Returns the StreamConfig of buffers that publisher creates.
60 /// This function will create the subscription between the publisher and
66 /// via the BufferSubscription they get from the publisher, then receive Frames
71 /// * The total number of on_next´s signalled by a Publisher to a Subscriber
[all …]
|
| /aosp_15_r20/tools/test/connectivity/acts/framework/tests/metrics/ |
| D | core_test.py | 94 publisher = MetricPublisher(context)
96 self.assertEqual(publisher.context, context)
104 publisher = MetricPublisher(context)
107 NotImplementedError, lambda: publisher.publish(metrics))
121 publisher = ProtoMetricPublisher(
128 self.assertEqual(publisher.context, context)
129 self.assertEqual(publisher.publishes_binary, publishes_binary)
130 self.assertEqual(publisher.publishes_ascii, publishes_ascii)
131 self.assertEqual(publisher.publishes_descriptor_binary,
133 self.assertEqual(publisher.publishes_descriptor_ascii,
[all …]
|
| /aosp_15_r20/cts/tests/controls/src/android/controls/cts/ |
| H A D | CtsControlsServiceTest.java | 49 import java.util.concurrent.Flow.Publisher;
73 Publisher<Control> publisher = mControlsService.createPublisherForAllAvailable(); in testLoadAllAvailable() local
75 subscribe(publisher, 10, loadedControls); in testLoadAllAvailable()
100 Publisher<Control> publisher = mControlsService.createPublisherForSuggested(); in testLoadSuggested() local
102 subscribe(publisher, 3, loadedControls); in testLoadSuggested()
120 Publisher<Control> publisher = mControlsService.createPublisherFor(idsToLoad); in testPublisherForSingleControl() local
122 subscribe(publisher, 10, loadedControls); in testPublisherForSingleControl()
136 Publisher<Control> publisher = mControlsService.createPublisherFor(idsToLoad); in testPublisherForMultipleControls() local
138 subscribe(publisher, 10, loadedControls); in testPublisherForMultipleControls()
152 Publisher<Control> publisher = mControlsService.createPublisherFor(idsToLoad); in testBooleanAction() local
[all …]
|
| /aosp_15_r20/external/google-cloud-java/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/ |
| H A 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 …]
|
| /aosp_15_r20/packages/services/Car/tests/CarTelemetryApp/tests/src/com/android/car/ |
| D | ConfigParserTest.java | 30 import android.car.telemetry.TelemetryProto.Publisher;
96 + " <publisher\n" in test_parseConfigReturnsCorrectMetricsConfig()
99 + " </publisher>\n" in test_parseConfigReturnsCorrectMetricsConfig()
130 Publisher pub = sub.getPublisher(); in test_parseConfigReturnsCorrectMetricsConfig()
150 + " <publisher\n" in test_emptyOrNoConfigNameReturnsNoConfig()
153 + " </publisher>\n" in test_emptyOrNoConfigNameReturnsNoConfig()
165 + " <publisher\n" in test_emptyOrNoConfigNameReturnsNoConfig()
168 + " </publisher>\n" in test_emptyOrNoConfigNameReturnsNoConfig()
192 + " <publisher\n" in test_malformedOrNoConfigVersionReturnsNoConfig()
195 + " </publisher>\n" in test_malformedOrNoConfigVersionReturnsNoConfig()
[all …]
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/ |
| H A 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 …]
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/ |
| H A 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 …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/ |
| H A D | Await.kt | 9 …* Awaits the first value from the given publisher without blocking the thread and returns the resu…
10 * the publisher has produced an error, throws the corresponding exception.
16 * @throws NoSuchElementException if the publisher does not emit any value
18 public suspend fun <T> Flow.Publisher<T>.awaitFirst(): T =
22 …* Awaits the first value from the given publisher, or returns the [default] value if none is emitt…
23 …* the thread, and returns the resulting value, or, if this publisher has produced an error, throws…
30 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrDefault(default: T): T =
34 …* Awaits the first value from the given publisher, or returns `null` if none is emitted, without b…
35 …* and returns the resulting value, or, if this publisher has produced an error, throws the corresp…
41 public suspend fun <T> Flow.Publisher<T>.awaitFirstOrNull(): T? =
[all …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/api/ |
| H A 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 …]
|