# | Line 655 | Line 655 | public class SubmissionPublisherTest ext | |
---|---|---|
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; |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |