| # | Line 1336 | Line 1336 | public class SubmissionPublisher<T> impl | |
|---|---|---|
| 1336 | } | |
| 1337 | } | |
| 1338 | } | |
| 1339 | < | else if (n < 0L) |
| 1339 | > | else |
| 1340 | onError(new IllegalArgumentException( | |
| 1341 | < | "negative subscription request")); |
| 1341 | > | "non-positive subscription request")); |
| 1342 | } | |
| 1343 | ||
| 1344 | public final boolean isReleasable() { // for ManagedBlocker | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |