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.29 by jsr166, Fri Jan 29 20:06:49 2016 UTC vs.
Revision 1.30 by jsr166, Tue Aug 30 19:42:16 2016 UTC

#	Line 39 | Line 39 | package java.util.concurrent;
39		*   private boolean subscribed; // true after first subscribe
40		*   public synchronized void subscribe(Subscriber<? super Boolean> subscriber) {
41		*     if (subscribed)
42	<	*        subscriber.onError(new IllegalStateException()); // only one allowed
42	>	*       subscriber.onError(new IllegalStateException()); // only one allowed
43		*     else {
44		*       subscribed = true;
45		*       subscriber.onSubscribe(new OneShotSubscription(subscriber, executor));

Diff Legend

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