@Test
public void onNext_CommitResponse() throws Exception {

  CommitResponse commitResponse = new CommitResponse("foo", true);
  underTest.onNext(commitResponse);
  verify(commitHandler).complete(commitResponse);
}