@Test @SuppressWarnings("unchecked") public void testThatOnIncreasePublishesAnEvent() { counter.increase(); verify(journal, timeout(TIMEOUT)).append(eq(streamName), eq(1), any(Source.class), any(), any()); }
@Override public void increase() { currentCount++; journal.append(counterName, version++, new CounterIncreased(currentCount), new MockCounterAppendResultInterest(), this); }
CounterActor extends Actor implements Counter { @Override public void increase() { currentCount++; journal.append(counterName, version++, new CounterIncreased(currentCount), new MockCounterAppendResultInterest(), this); } }
CounterActor extends Actor implements Counter { @Override public void increase() { currentCount++; journal.append(counterName, version++, new CounterIncreased(currentCount), new MockCounterAppendResultInterest(), this); } CounterActor(final String counterName, final Journal<String> journal); }
CounterActor extends Actor implements Counter { @Override public void increase() { currentCount++; journal.append(counterName, version++, new CounterIncreased(currentCount), new MockCounterAppendResultInterest(), this); } CounterActor(final String counterName, final Journal<String> journal); @Override void increase(); @Override void decrease(); }
CounterActor extends Actor implements Counter { @Override public void increase() { currentCount++; journal.append(counterName, version++, new CounterIncreased(currentCount), new MockCounterAppendResultInterest(), this); } CounterActor(final String counterName, final Journal<String> journal); @Override void increase(); @Override void decrease();  }