public CompletableFuture<WorkerStatusResponse> getWorkerStatus() {
    WorkerStatusRequest request =
        WorkerStatusRequest.newBuilder().setId(idGenerator.getId()).build();
    return getWorkerStatus(request);
  }
@Test
  @SuppressWarnings("FutureReturnValueIgnored")
  public void testGetWorkerStatusRequestSent() {
    client.getWorkerStatus();
    verify(mockObserver).onNext(any(WorkerStatusRequest.class));
  }