Method callbackWithTimeout

test/TestHBaseRpc.java:231–246

()

  }
  
  @Test
  public void callbackWithTimeout() throws Exception {
    final GetRequest rpc = new GetRequest(TABLE, KEY, FAMILY);
    rpc.attempt = 4;
    final Timeout timeout_handle = mock(Timeout.class);
    final Deferred<Object> deferred = rpc.getDeferred();
    final Object response = new Object();
    rpc.timeout_handle = timeout_handle;
    assertTrue(rpc.hasDeferred());
    
    rpc.callback(response);
    assertSame(response, deferred.join());
    assertEquals(0, rpc.attempt);
    assertFalse(rpc.hasDeferred());
    verify(timeout_handle).cancel();
  }
  
  @Test
  public void callbackWithoutDeferred() throws Exception {