Merge "Track addition of Flow.* to the public API."
This commit is contained in:
@@ -72380,6 +72380,29 @@ package java.util.concurrent {
|
||||
method public static java.util.concurrent.ScheduledExecutorService unconfigurableScheduledExecutorService(java.util.concurrent.ScheduledExecutorService);
|
||||
}
|
||||
|
||||
public final class Flow {
|
||||
method public static int defaultBufferSize();
|
||||
}
|
||||
|
||||
public static interface Flow.Processor<T, R> extends java.util.concurrent.Flow.Subscriber<T> java.util.concurrent.Flow.Publisher<R> {
|
||||
}
|
||||
|
||||
@java.lang.FunctionalInterface public static interface Flow.Publisher<T> {
|
||||
method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);
|
||||
}
|
||||
|
||||
public static interface Flow.Subscriber<T> {
|
||||
method public void onComplete();
|
||||
method public void onError(Throwable);
|
||||
method public void onNext(T);
|
||||
method public void onSubscribe(java.util.concurrent.Flow.Subscription);
|
||||
}
|
||||
|
||||
public static interface Flow.Subscription {
|
||||
method public void cancel();
|
||||
method public void request(long);
|
||||
}
|
||||
|
||||
public class ForkJoinPool extends java.util.concurrent.AbstractExecutorService {
|
||||
ctor public ForkJoinPool();
|
||||
ctor public ForkJoinPool(int);
|
||||
|
||||
Reference in New Issue
Block a user