Review the inherited state of V1 waiters and determine which changes are necessary for

Hey all, we have released waiters in 2.15.0 . <p d

Feature Request from v1: <a class="issue-link js-issue-link" data-error-text="Failed t

Waiters about aws-sdk-java-v2 HOT 6 CLOSED

aws commented on July 18, 2024 4

Waiters

from aws-sdk-java-v2.

Comments (6)

rleibman commented on July 18, 2024 2

This is what I'm doing in Scala using the async clients. I imagine you could do something similar in java.

def whileInProgress[Request <: AmazonWebServiceRequest, Response](
    method: Request => java.util.concurrent.CompletableFuture[Response],
    request: Request,
    isInProgress: Response ⇒ Boolean,
    duration: Duration = 30 seconds): Future[Response] = {
    def loop(): Future[Response] = {
      val fut = method(request).toScala
      fut.flatMap { response =>
        if (isInProgress(response)) {
          Thread.sleep(duration.toMillis)
          loop
        }
        fut
      }
    }

    loop
  }

from aws-sdk-java-v2.

yellowstonesoftware commented on July 18, 2024 1

Is this ever going to be implemented?

from aws-sdk-java-v2.

zoewangg commented on July 18, 2024 1

Hey all, we have released waiters in 2.15.0.

Below is the sample code of how to use it:

sync waiter:

DynamoDbClient dynamo = DynamoDbClient.create();
DynamoDbWaiter waiter = dynamo.waiter();

WaiterResponse<DescribeTableResponse> waiterResponse =
   waiter.waitUntilTableExists(r -> r.tableName("myTable"));

// print out the matched response with a tableStatus of ACTIVE
waiterResponse.matched().response().ifPresent(System.out::println);

async waiter

DynamoDbAsyncClient asyncDynamo = DynamoDbAsyncClient.create();
DynamoDbAsyncWaiter asyncWaiter = asyncDynamo.waiter();

CompletableFuture<WaiterResponse<DescribeTableResponse>> waiterResponse =
                    asyncWaiter.waitUntilTableNotExists(r -> r.tableName("myTable"));

waiterResponse.whenComplete((r, t) -> {
   if (t == null) {
      // print out the matched ResourceNotFoundException
      r.matched().exception().ifPresent(System.out::println);
   }
}).join();