@Test
public void commit() throws Exception {

  doReturn(Mono.just(true)).when(commitHandler).commit(singletonMap(0, 1L));
  Boolean result = underTest.commit(singletonMap(0, 1L)).block();
  assertThat(result, is(true));
}