import akka.actor.ActorSystem;
import akka.testkit.TestProbe;
import com.google.common.testing.FakeTicker;
-import java.util.Optional;
+import java.util.OptionalLong;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
@Test
public void testSendRequestNeedsBackend() {
queue.sendRequest(mockRequest, mockCallback);
- final Optional<Long> ret = queue.checkTimeout(ticker.read());
+ final OptionalLong ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
}
setupBackend();
queue.sendRequest(mockRequest, mockCallback);
- final Optional<Long> ret = queue.checkTimeout(ticker.read());
+ final OptionalLong ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
assertTransmit(mockRequest, 0);
@Test
public void testRunTimeoutEmpty() {
- Optional<Long> ret = queue.checkTimeout(ticker.read());
+ OptionalLong ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertFalse(ret.isPresent());
}
@Test
public void testRunTimeoutWithoutShift() {
queue.sendRequest(mockRequest, mockCallback);
- Optional<Long> ret = queue.checkTimeout(ticker.read());
+ OptionalLong ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
}
ticker.advance(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS - 1);
- Optional<Long> ret = queue.checkTimeout(ticker.read());
+ OptionalLong ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
}
ticker.advance(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS);
- Optional<Long> ret = queue.checkTimeout(ticker.read());
+ OptionalLong ret = queue.checkTimeout(ticker.read());
assertNull(ret);
}
ticker.advance(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS + 1);
- Optional<Long> ret = queue.checkTimeout(ticker.read());
- assertNull(ret);
+ assertNull(queue.checkTimeout(ticker.read()));
}
@SuppressWarnings({ "rawtypes", "unchecked" })
ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS);
// No problem
- Optional<Long> ret = queue.checkTimeout(ticker.read());
- assertNotNull(ret);
- assertFalse(ret.isPresent());
+ assertEquals(OptionalLong.empty(), queue.checkTimeout(ticker.read()));
}
@Test
ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS + 1);
// No problem
- Optional<Long> ret = queue.checkTimeout(ticker.read());
- assertNotNull(ret);
- assertFalse(ret.isPresent());
+ assertEquals(OptionalLong.empty(), queue.checkTimeout(ticker.read()));
}
@Test
ticker.advance(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS - 11);
- Optional<Long> ret = queue.checkTimeout(ticker.read());
- assertNull(ret);
+ assertNull(queue.checkTimeout(ticker.read()));
}
private void setupBackend() {