@Test
public void onNext() throws Exception {

  Message<String> message = new Message<>(0, 1L, 2, 3L, "foo");
  underTest.subscribe(subscriber);
  underTest.onNext(message);
  verify(subscriber).onNext(message);
}