655 |
|
return false; |
656 |
|
} |
657 |
|
|
658 |
< |
static boolean reqHandle(AtomicInteger count, Subscriber s) { |
658 |
> |
static boolean reqHandle(AtomicInteger count, Subscriber<?> s) { |
659 |
|
count.getAndIncrement(); |
660 |
|
((TestSubscriber)s).sn.request(Long.MAX_VALUE); |
661 |
|
return true; |
958 |
|
public void testConsumeNPE() { |
959 |
|
SubmissionPublisher<Integer> p = basicPublisher(); |
960 |
|
try { |
961 |
< |
CompletableFuture<Void> f = p.consume(null); |
961 |
> |
CompletableFuture<Void> unused = p.consume(null); |
962 |
|
shouldThrow(); |
963 |
|
} catch (NullPointerException success) {} |
964 |
|
} |