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.31 by dl, Thu Mar 9 00:11:08 2017 UTC vs.
Revision 1.32 by dl, Fri Aug 4 23:05:47 2017 UTC

# Line 56 | Line 56 | package java.util.concurrent;
56   *       this.executor = executor;
57   *     }
58   *     public synchronized void request(long n) {
59 < *       if (n != 0 && !completed) {
59 > *       if (!completed) {
60   *         completed = true;
61 < *         if (n < 0) {
61 > *         if (n <= 0) {
62   *           IllegalArgumentException ex = new IllegalArgumentException();
63   *           executor.execute(() -> subscriber.onError(ex));
64   *         } else {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines