await("Sending of 1. message for A is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultA1.isDone());
Assertions.assertThat(resultA1.isCompletedExceptionally()).isFalse();
await("Sending of 1. message for A is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultA1.isDone());
Assertions.assertThat(resultA1.isCompletedExceptionally()).isFalse();
await("Sending of 1. message for B is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultB1.isDone());
Assertions.assertThat(resultB1.isCompletedExceptionally()).isFalse();
await("Sending of 1. message for B is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultB1.isDone());
Assertions.assertThat(resultB1.isCompletedExceptionally()).isFalse();
await("Sending of 2. message for A is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultA2.isDone());
await("Sending of 2. message for A is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultA2.isDone());
await("Sending of 2. message for B is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultB2.isDone());
await("Sending of 2. message for B is completed")
.atMost(Duration.ofSeconds(5))
.until(() -> resultB2.isDone());