ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/Flow.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/Flow.java (file contents):
Revision 1.21 by dl, Sat Jan 24 20:58:59 2015 UTC vs.
Revision 1.22 by dl, Sun Jan 25 15:19:40 2015 UTC

# Line 65 | Line 65 | import java.util.stream.Stream;
65   *         completed = true;
66   *         if (n < 0) {
67   *           IllegalStateException ex = new IllegalStateException();
68 < *           executor.submit(() -> subscriber.onError(ex));
68 > *           executor.execute(() -> subscriber.onError(ex));
69   *         }
70   *         else {
71   *           future = executor.submit(() -> {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines