# | Line 404 | Line 404 | public class SubmissionPublisherTest ext | |
---|---|---|
404 | */ | |
405 | public void testCancel() { | |
406 | SubmissionPublisher<Integer> p = | |
407 | < | new SubmissionPublisher<Integer>(basicExecutor, 4); // must be < 20 |
407 | > | new SubmissionPublisher<>(basicExecutor, 4); // must be < 20 |
408 | TestSubscriber s1 = new TestSubscriber(); | |
409 | TestSubscriber s2 = new TestSubscriber(); | |
410 | p.subscribe(s1); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |