774 |
|
assertTrue(calls.get() >= 4); |
775 |
|
} |
776 |
|
|
777 |
– |
|
777 |
|
/** |
778 |
|
* offer succeeds if drop handler forces request |
779 |
|
*/ |
801 |
|
assertTrue(calls.get() >= 2); |
802 |
|
} |
803 |
|
|
805 |
– |
|
804 |
|
/** |
805 |
< |
* TimedOffer to a publisher with no subscribers returns lag 0 |
805 |
> |
* Timed offer to a publisher with no subscribers returns lag 0 |
806 |
|
*/ |
807 |
|
public void testEmptyTimedOffer() { |
808 |
|
SubmissionPublisher<Integer> p = basicPublisher(); |
809 |
< |
assertEquals(p.offer(1, null), 0); |
809 |
> |
assertEquals(0, p.offer(1, LONG_DELAY_MS, MILLISECONDS, null)); |
810 |
|
} |
811 |
|
|
812 |
|
/** |
933 |
|
assertTrue(calls.get() >= 2); |
934 |
|
} |
935 |
|
|
938 |
– |
|
936 |
|
} |