@Test
public void shouldForwardMessagesToConsumer() throws Exception {

  new MessageDispatcher<String>(WorkRunners.immediate(), messages::add).accept("hey hello");
  assertThat(messages).containsExactly("hey hello");
}