@Test
public void shouldOnlySupportASingleSubscriber() throws Exception {

  eventSubject.subscribe(receiver);
  assertThatThrownBy(() -> eventSubject.subscribe(new RecordingConsumer<>()))
      .isInstanceOf(IllegalStateException.class);
}