@Test
public void shouldOnlyEmitStateStateChanged() throws Exception {

  underTest.update(0);
  underTest.update(1);
  underTest.update(0);
  underTest.update(2);
  stateConsumer.assertValues("init!->1", "init!->1->2");
}