| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Flow.kt | 198 public suspend fun collect(collector: FlowCollector<T>) in collect() method
227 public final override suspend fun collect(collector: FlowCollector<T>) { in collect() method in kotlinx.coroutines.flow.AbstractFlow
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/terminal/ |
| D | Collect.kt | 30 public suspend fun Flow<*>.collect(): Unit = collect(NopCollector) in collect() method
114 public suspend inline fun <T> Flow<T>.collect(crossinline action: suspend (value: T) -> Unit): Unit… in collect() method
|
| /external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| D | ICUCurrencyMetaInfo.java | 73 private <T> List<T> collect(Collector<T> collector, CurrencyFilter filter) { in collect() method in ICUCurrencyMetaInfo
205 …public void collect(String region, String currency, long from, long to, int priority, boolean tend… in collect() method in ICUCurrencyMetaInfo.InfoCollector
224 public void collect( in collect() method in ICUCurrencyMetaInfo.RegionCollector
244 public void collect( in collect() method in ICUCurrencyMetaInfo.CurrencyCollector
282 … void collect(String region, String currency, long from, long to, int priority, boolean tender); in collect() method
|
| /external/icu/icu4j/main/classes/currdata/src/com/ibm/icu/impl/ |
| D | ICUCurrencyMetaInfo.java | 71 private <T> List<T> collect(Collector<T> collector, CurrencyFilter filter) { in collect() method in ICUCurrencyMetaInfo
203 …public void collect(String region, String currency, long from, long to, int priority, boolean tend… in collect() method in ICUCurrencyMetaInfo.InfoCollector
222 public void collect( in collect() method in ICUCurrencyMetaInfo.RegionCollector
242 public void collect( in collect() method in ICUCurrencyMetaInfo.CurrencyCollector
280 … void collect(String region, String currency, long from, long to, int priority, boolean tender); in collect() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxChannel.kt | 20 public suspend inline fun <T> MaybeSource<T>.collect(action: (T) -> Unit): Unit = in collect() method
29 public suspend inline fun <T> ObservableSource<T>.collect(action: (T) -> Unit): Unit = in collect() method
|
| /external/mesa3d/src/freedreno/ir3/ |
| D | ir3_group.c | 34 insert_mov(struct ir3_instruction *collect, int idx) in insert_mov()
71 group_collect(struct ir3_instruction *collect) in group_collect()
|
| /external/rust/crates/indexmap/src/rayon/ |
| D | mod.rs | 12 fn collect<I: IntoParallelIterator>(iter: I) -> LinkedList<Vec<I::Item>> { in collect() function
|
| /external/rust/crates/hashbrown/src/external_trait_impls/rayon/ |
| D | helpers.rs | 8 pub(super) fn collect<I: IntoParallelIterator>(iter: I) -> (LinkedList<Vec<I::Item>>, usize) { in collect() function
|
| /external/javaparser/javaparser-core/src/main/java/com/github/javaparser/utils/ |
| D | CollectionStrategy.java | 20 ProjectRoot collect(Path path); in collect() method
|
| D | ParserCollectionStrategy.java | 32 public ProjectRoot collect(Path path) { in collect() method in ParserCollectionStrategy
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/ |
| D | Streams.java | 211 public <A, R> R collect(final Collector<? super O, A, R> collector) { in collect() method in Streams.FailableStream
269 …public <A, R> R collect(final Supplier<R> supplier, final BiConsumer<R, ? super O> accumulator, fi… in collect() method in Streams.FailableStream
|
| /external/javaparser/javaparser-symbol-solver-core/src/main/java/com/github/javaparser/symbolsolver/utils/ |
| D | SymbolSolverCollectionStrategy.java | 38 public ProjectRoot collect(Path path) { in collect() method in SymbolSolverCollectionStrategy
|
| /external/tensorflow/tensorflow/python/ops/ |
| D | summary_op_util.py | 24 def collect(val, collections, default_collections): function
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jdk8/src/stream/ |
| D | Stream.kt | 22 override suspend fun collect(collector: FlowCollector<T>) { in consumeAsFlow() method in kotlinx.coroutines.stream.StreamFlow
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/ |
| D | ReactiveFlow.kt | 48 public suspend inline fun <T> JFlow.Publisher<T>.collect(action: (T) -> Unit): Unit = method
|
| /external/opencensus-java/contrib/dropwizard/src/test/java/io/opencensus/contrib/dropwizard/ |
| D | DropWizardMetricsTest.java | 58 public void collect() throws InterruptedException { in collect() method in DropWizardMetricsTest
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/ |
| D | InstrumentingLoader.java | 81 public ExecutionDataStore collect() { in collect() method in InstrumentingLoader
|
| /external/angle/src/libANGLE/renderer/vulkan/ |
| D | PersistentCommandPool.cpp | 87 angle::Result PersistentCommandPool::collect(Context *context, PrimaryCommandBuffer &&buffer) in collect() function in rx::vk::PersistentCommandPool
|
| D | SecondaryCommandPool.cpp | 79 void SecondaryCommandPool::collect(VulkanSecondaryCommandBuffer *buffer) in collect() function in rx::vk::SecondaryCommandPool
|
| /external/opencensus-java/exporters/stats/prometheus/src/main/java/io/opencensus/exporter/stats/prometheus/ |
| D | PrometheusStatsCollector.java | 95 public List<MetricFamilySamples> collect() { in collect() method in PrometheusStatsCollector
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | ChannelFlow.kt | 121 override suspend fun collect(collector: FlowCollector<T>): Unit = in create() method in kotlinx.coroutines.flow.internal.ChannelFlow
160 override suspend fun collect(collector: FlowCollector<T>) { in collectTo() method
|
| D | SafeCollector.common.kt | 107 override suspend fun collect(collector: FlowCollector<T>) { in unsafeFlow() method
|
| /external/turbine/javatests/com/google/turbine/bytecode/sig/ |
| D | SigRegressionTest.java | 32 public void collect() { in collect() method in SigRegressionTest
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/stream/ |
| D | Streams.java | 301 public <A, R> R collect(final Collector<? super T, A, R> collector) { in collect() method in FailableStream
358 …public <A, R> R collect(final Supplier<R> supplier, final BiConsumer<R, ? super T> accumulator, fi… in collect() method in FailableStream
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Context.kt | 272 override suspend fun collect(collector: FlowCollector<T>) { in collect() method in kotlinx.coroutines.flow.CancellableFlowImpl
|