Home
last modified time | relevance | path

Searched refs:Flow (Results 1 – 7 of 7) sorted by relevance

/libcore/luni/src/test/java/libcore/java/util/concurrent/
DFlowTest.java21 import java.util.concurrent.Flow;
37 assertEquals(256, Flow.defaultBufferSize()); in testDefaultBufferSize()
/libcore/ojluni/src/main/java/java/util/concurrent/
DFlow.java166 public final class Flow { class
168 private Flow() {} // uninstantiable in Flow() method in Flow
DSubmissionPublisher.java48 import static java.util.concurrent.Flow.Publisher;
49 import static java.util.concurrent.Flow.Subscriber;
50 import static java.util.concurrent.Flow.Subscription;
317 this(ASYNC_POOL, Flow.defaultBufferSize(), null); in SubmissionPublisher()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DSubmissionPublisherTest.java40 import java.util.concurrent.Flow;
47 import static java.util.concurrent.Flow.Subscriber;
48 import static java.util.concurrent.Flow.Subscription;
180 assertEquals(p.getMaxBufferCapacity(), Flow.defaultBufferSize()); in testConstructor1()
/libcore/api/
Dcurrent.txt15944 public final class Flow {
15948 …public static interface Flow.Processor<T, R> extends java.util.concurrent.Flow.Subscriber<T> java.…
15951 @java.lang.FunctionalInterface public static interface Flow.Publisher<T> {
15952 method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);
15955 public static interface Flow.Subscriber<T> {
15959 method public void onSubscribe(java.util.concurrent.Flow.Subscription);
15962 public static interface Flow.Subscription {
16313 …public class SubmissionPublisher<T> implements java.lang.AutoCloseable java.util.concurrent.Flow.P…
16314 …Executor, int, java.util.function.BiConsumer<? super java.util.concurrent.Flow.Subscriber<? super …
16326 method public java.util.List<java.util.concurrent.Flow.Subscriber<? super T>> getSubscribers();
[all …]
/libcore/
Dopenjdk_java_files.bp1001 "ojluni/src/main/java/java/util/concurrent/Flow.java",
DEXPECTED_UPSTREAM1052 …rc/main/java/java/util/concurrent/Flow.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…