OutboxImpl implements OutboxInternal { final boolean offerToEdgesAndSnapshot(Object item) { return offerInternal(allEdgesAndSnapshot, item); } OutboxImpl(OutboundCollector[] outstreams, boolean hasSnapshot, ProgressTracker progTracker,
                      SerializationService serializationService, int batchSize, AtomicLongArray counters); @Override final int bucketCount(); @Override final boolean offer(int ordinal, @Nonnull Object item); @Override final boolean offer(@Nonnull int[] ordinals, @Nonnull Object item); @Override final boolean offer(@Nonnull Object item); @Override final boolean offerToSnapshot(@Nonnull Object key, @Nonnull Object value); @Override boolean hasUnfinishedItem(); @Override void block(); @Override void unblock(); @Override void reset(); @Override long lastForwardedWm();  }
@Test public void when_offer5_then_rateLimited() { do_when_offer_then_rateLimited(e -> outbox.offerToEdgesAndSnapshot(e)); }
@Test public void when_offer5FailsAndDifferentItemOffered_then_fail() { do_when_offerDifferent_then_fail(e -> outbox.offerToEdgesAndSnapshot(e)); }