Mockito invoking callback
@Mock
BiConsumer<Integer, Runnable> onNext;
doAnswer((Answer<Void>) invocation ->{
Runnable readNext = invocation.getArgument(1);
readNext.run();
return null;
}).when(onNext).accept(anyInt(), any(Runnable.class));