AbstractProcessor implements Processor { @CheckReturnValue protected final boolean tryEmit(int ordinal, @Nonnull Object item) { return outbox.offer(ordinal, item); }  @Override final void init(@Nonnull Outbox outbox, @Nonnull Context context); @Override final void restoreFromSnapshot(@Nonnull Inbox inbox); @Override @SuppressWarnings("checkstyle:magicnumber") void process(int ordinal, @Nonnull Inbox inbox); @Override boolean tryProcessWatermark(@Nonnull Watermark watermark);  }
@Test public void when_tryEmitToAll_then_emittedToAll() { boolean emitted = p.tryEmit(MOCK_ITEM); assertTrue(emitted); validateReceptionAtOrdinals(MOCK_ITEM, ALL_ORDINALS); }
@Test public void when_tryEmitTo1_then_emittedTo1() { boolean emitted = p.tryEmit(ORDINAL_1, MOCK_ITEM); assertTrue(emitted); validateReceptionAtOrdinals(MOCK_ITEM, ORDINAL_1); }
@Test public void when_tryEmitTo1And2_then_emittedTo1And2() { boolean emitted = p.tryEmit(ORDINALS_1_2, MOCK_ITEM); assertTrue(emitted); validateReceptionAtOrdinals(MOCK_ITEM, ORDINALS_1_2); }