public static void main(String[] args) throws Exception {
    Server server =
        ServerBuilder.forPort(1234)
            .addService(
                new BigtableImplBase() {
                  @Override
                  public void readRows(
                      ReadRowsRequest request, StreamObserver<ReadRowsResponse> responseObserver) {
                    System.out.println(Context.current().getDeadline());
                    try {
                      Thread.sleep(100);
                    } catch (InterruptedException e) {
                      responseObserver.onError(e);
                      return;
                    }
                    responseObserver.onError(Status.UNAVAILABLE.asException());
                  }
                })
            .build();

    server.start();
    server.awaitTermination();
  }