import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
-import com.google.common.util.concurrent.ListenableFuture;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.List;
@Test
public void testStartup1() throws UnknownHostException {
startUp(null);
- final ListenableFuture<Boolean> future = provider.startup();
+ final var future = provider.startup();
final var cause = assertThrows(ExecutionException.class, () -> future.get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS))
.getCause();
public void testStartup2() throws UnknownHostException {
startUp(null);
provider.setSwitchConnectionHandler(handler);
- final ListenableFuture<Boolean> future = provider.startup();
+ final var future = provider.startup();
final var cause = assertThrows(ExecutionException.class, () -> future.get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS))
.getCause();
@Test
public void testStartup3() throws UnknownHostException {
startUp(TransportProtocol.TCP);
- final ListenableFuture<Boolean> future = provider.startup();
+ final var future = provider.startup();
final var cause = assertThrows(ExecutionException.class, () -> future.get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS))
.getCause();
startUp(TransportProtocol.TCP);
provider.setSwitchConnectionHandler(handler);
- assertTrue("Failed to start", provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS));
+ provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS);
}
/**
startUp(TransportProtocol.TLS);
provider.setSwitchConnectionHandler(handler);
- assertTrue("Failed to start", provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS));
+ provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS);
}
/**
startUp(TransportProtocol.UDP);
provider.setSwitchConnectionHandler(handler);
- assertTrue("Failed to start", provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS));
+ provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS);
}
/**
startUp(TransportProtocol.TCP);
provider.setSwitchConnectionHandler(handler);
- assertTrue("Failed to start", provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS));
+ provider.startup().get(WAIT_TIMEOUT, TimeUnit.MILLISECONDS);
assertTrue("Failed to stop", provider.shutdown().get(5 * WAIT_TIMEOUT, TimeUnit.MILLISECONDS));
}
}