# | Line 334 | Line 334 | public class SubmissionPublisherTest ext | |
---|---|---|
334 | TestSubscriber s = new TestSubscriber(); | |
335 | SubmissionPublisher<Integer> p = basicPublisher(); | |
336 | s.throwOnCall = true; | |
337 | < | try { |
338 | < | p.subscribe(s); |
339 | < | } catch (Exception ok) {} |
337 | > | p.subscribe(s); |
338 | s.awaitError(); | |
339 | assertEquals(0, s.nexts); | |
340 | assertEquals(1, s.errors); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |