ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/main/java/util/concurrent/Flow.java

Comparing jsr166/src/main/java/util/concurrent/Flow.java (file contents):
Revision 1.10 by dl, Sun Jan 18 23:06:59 2015 UTC vs.
Revision 1.11 by dl, Sun Jan 18 23:21:35 2015 UTC

#	Line 39 | Line 39 | import java.util.stream.Stream;
39		* class OneShotPublisher implements Publisher<Boolean> {
40		*   final Executor executor = Executors.newSingleThreadExecutor();
41		*   public void subscribe(Subscriber<? super Boolean> subscriber) {
42	<	*       subscriber.onSubscribe(new OneShotSubscription(subscriber));
42	>	*       subscriber.onSubscribe(new OneShotSubscription(subscriber, executor));
43		*   }
44		*   static class OneShotSubscription implements Subscription {
45		*     final Subscriber<? super Boolean> subscriber;

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines