< prev index next >

jdk/src/java.base/share/classes/java/util/concurrent/SubmissionPublisher.java

Print this page

        

*** 152,162 **** * public void onComplete() { close(); } * }}</pre> * * @param <T> the published item type * @author Doug Lea ! * @since 1.9 */ public class SubmissionPublisher<T> implements Flow.Publisher<T>, AutoCloseable { /* * Most mechanics are handled by BufferedSubscription. This class --- 152,162 ---- * public void onComplete() { close(); } * }}</pre> * * @param <T> the published item type * @author Doug Lea ! * @since 9 */ public class SubmissionPublisher<T> implements Flow.Publisher<T>, AutoCloseable { /* * Most mechanics are handled by BufferedSubscription. This class
< prev index next >