# | 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 { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |