@Test
public void shouldPermitUsingConnectablesAsAnEventSource() throws Exception {

  ConnectableTestEventSource eventSource = new ConnectableTestEventSource();
  loop =
      Mobius.loop(UPDATE, HANDLER)
          .eventRunner(WorkRunners::immediate)
          .eventSource(eventSource)
          .startFrom(MY_MODEL);
  eventSource.consumer.accept(7);
  await().atMost(Duration.ofSeconds(1)).until(() -> loop.getMostRecentModel(), is("start7"));
}