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 {
