402 |
|
* Cancelling a subscription eventually causes no more onNexts to be issued |
403 |
|
*/ |
404 |
|
public void testCancel() { |
405 |
< |
SubmissionPublisher<Integer> p = basicPublisher(); |
405 |
> |
SubmissionPublisher<Integer> p = |
406 |
> |
new SubmissionPublisher<Integer>(basicExecutor, 4); // must be < 20 |
407 |
|
TestSubscriber s1 = new TestSubscriber(); |
408 |
|
TestSubscriber s2 = new TestSubscriber(); |
409 |
|
p.subscribe(s1); |
640 |
|
p.subscribe(s1); |
641 |
|
p.subscribe(s2); |
642 |
|
for (int i = 1; i <= 20; ++i) { |
642 |
– |
assertTrue(p.estimateMinimumDemand() <= 1); |
643 |
|
assertTrue(p.submit(i) >= 0); |
644 |
|
} |
645 |
|
p.close(); |