@Test public void testResponseOutOfOrder() throws Exception { MutateRowsRequest request = createRequest(2); RetryingMutateRowsOperation underTest = createOperation(request); ListenableFuture<?> future = underTest.getAsyncResult(); send(underTest, createResponse(toEntry(1, DEADLINE_EXCEEDED), toEntry(0, OK))); checkExecutor(1); Assert.assertEquals(createRequest(request.getEntries(1)), underTest.getRetryRequest()); send(underTest, OK); checkResponse(future, createResponse(OK, OK)); }
@Override protected MutateRowsRequest getRetryRequest() { return requestManager.getRetryRequest(); }
RetryingMutateRowsOperation extends AbstractRetryingOperation<
        MutateRowsRequest, MutateRowsResponse, List<MutateRowsResponse>> { @Override protected MutateRowsRequest getRetryRequest() { return requestManager.getRetryRequest(); } }
RetryingMutateRowsOperation extends AbstractRetryingOperation<
        MutateRowsRequest, MutateRowsResponse, List<MutateRowsResponse>> { @Override protected MutateRowsRequest getRetryRequest() { return requestManager.getRetryRequest(); } RetryingMutateRowsOperation(
      RetryOptions retryOptions,
      MutateRowsRequest originalRequest,
      BigtableAsyncRpc<MutateRowsRequest, MutateRowsResponse> retryableRpc,
      CallOptions callOptions,
      ScheduledExecutorService retryExecutorService,
      Metadata originalMetadata,
      ApiClock clock); }
RetryingMutateRowsOperation extends AbstractRetryingOperation<
        MutateRowsRequest, MutateRowsResponse, List<MutateRowsResponse>> { @Override protected MutateRowsRequest getRetryRequest() { return requestManager.getRetryRequest(); } RetryingMutateRowsOperation(
      RetryOptions retryOptions,
      MutateRowsRequest originalRequest,
      BigtableAsyncRpc<MutateRowsRequest, MutateRowsResponse> retryableRpc,
      CallOptions callOptions,
      ScheduledExecutorService retryExecutorService,
      Metadata originalMetadata,
      ApiClock clock); @Override void onMessage(MutateRowsResponse message); }
RetryingMutateRowsOperation extends AbstractRetryingOperation<
        MutateRowsRequest, MutateRowsResponse, List<MutateRowsResponse>> { @Override protected MutateRowsRequest getRetryRequest() { return requestManager.getRetryRequest(); } RetryingMutateRowsOperation(
      RetryOptions retryOptions,
      MutateRowsRequest originalRequest,
      BigtableAsyncRpc<MutateRowsRequest, MutateRowsResponse> retryableRpc,
      CallOptions callOptions,
      ScheduledExecutorService retryExecutorService,
      Metadata originalMetadata,
      ApiClock clock); @Override void onMessage(MutateRowsResponse message);  }