+
+ @Test
+ public void testPauseLeaderTimeout() {
+ pauseLeaderFunction = new Function<Runnable, Void>() {
+ @Override
+ public Void apply(Runnable input) {
+ return null;
+ }
+ };
+
+ setup();
+ cohort.init();
+ verify(onComplete, timeout(2000)).onFailure(mockRaftActor.self(), null);
+ }