equal
deleted
inserted
replaced
552 b = next; |
552 b = next; |
553 } |
553 } |
554 while (r != null) { |
554 while (r != null) { |
555 BufferedSubscription<T> nextRetry = r.nextRetry; |
555 BufferedSubscription<T> nextRetry = r.nextRetry; |
556 r.nextRetry = null; |
556 r.nextRetry = null; |
557 int stat = (nanos > 0L) ? r.timedOffer(item, nanos) : |
557 int stat = (nanos > 0L) |
558 r.offer(item); |
558 ? r.timedOffer(item, nanos) |
|
559 : r.offer(item); |
559 if (stat == 0 && onDrop != null && |
560 if (stat == 0 && onDrop != null && |
560 onDrop.test(r.subscriber, item)) |
561 onDrop.test(r.subscriber, item)) |
561 stat = r.offer(item); |
562 stat = r.offer(item); |
562 if (stat == 0) |
563 if (stat == 0) |
563 ++drops; |
564 ++drops; |