private List<Event> peekOrPoll(String subscription, @Nullable Duration claimTtl, int limit) {
List<Item> items = Lists.newArrayList();
Map<Coordinate, Item> uniqueItems = Maps.newHashMap();
Map<Coordinate, Integer> eventOrder = Maps.newHashMap();
boolean repeatable = claimTtl != null && claimTtl.getMillis() > 0;
<BUG>long stop = _ticker.read() + TimeUnit.MILLISECONDS.toNanos(MAX_POLL_TIME.getMillis());
int padding = 0;</BUG>
do {
int remaining = limit - items.size();
if (remaining == 0) {

private List<Event> peekOrPoll(String subscription, @Nullable Duration claimTtl, int limit) {
List<Item> items = Lists.newArrayList();
Map<Coordinate, Item> uniqueItems = Maps.newHashMap();
Map<Coordinate, Integer> eventOrder = Maps.newHashMap();
boolean repeatable = claimTtl != null && claimTtl.getMillis() > 0;
Stopwatch stopwatch = Stopwatch.createStarted(_ticker);
int padding = 0;
do {
int remaining = limit - items.size();
if (remaining == 0) {
