Skip to content

Commit be4f89e

Browse files
committed
Fix integ tests
1 parent 8bfa54f commit be4f89e

File tree

2 files changed

+9
-9
lines changed
  • examples

2 files changed

+9
-9
lines changed

examples/end-to-end/src/it/java/software/amazon/smithy/java/server/example/RoundTripTests.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -60,31 +60,31 @@ void setupClient() {
6060
@Test
6161
void executesCorrectly() throws InterruptedException {
6262
var menu = client.getMenu(GetMenuInput.builder().build());
63-
var hasEspresso = menu.items().stream().anyMatch(item -> item.typeMember().equals(CoffeeType.ESPRESSO));
63+
var hasEspresso = menu.getItems().stream().anyMatch(item -> item.getTypeMember().equals(CoffeeType.ESPRESSO));
6464
assertTrue(hasEspresso);
6565

6666
var createRequest = CreateOrderInput.builder().coffeeType(CoffeeType.COLD_BREW).build();
6767
var createResponse = client.createOrder(createRequest);
68-
assertEquals(CoffeeType.COLD_BREW, createResponse.coffeeType());
69-
System.out.println("Created request with id = " + createResponse.id());
68+
assertEquals(CoffeeType.COLD_BREW, createResponse.getCoffeeType());
69+
System.out.println("Created request with id = " + createResponse.getId());
7070

71-
var getRequest = GetOrderInput.builder().id(createResponse.id()).build();
71+
var getRequest = GetOrderInput.builder().id(createResponse.getId()).build();
7272
var getResponse1 = client.getOrder(getRequest);
73-
assertEquals(getResponse1.status(), OrderStatus.IN_PROGRESS);
73+
assertEquals(getResponse1.getStatus(), OrderStatus.IN_PROGRESS);
7474

7575
// Complete the order
76-
OrderTracker.completeOrder(getResponse1.id());
76+
OrderTracker.completeOrder(getResponse1.getId());
7777

7878
var getResponse2 = client.getOrder(getRequest);
79-
assertEquals(getResponse2.status(), OrderStatus.COMPLETED);
79+
assertEquals(getResponse2.getStatus(), OrderStatus.COMPLETED);
8080
System.out.println("Completed Order :" + getResponse2);
8181
}
8282

8383
@Test
8484
void errorsOutIfOrderDoesNotExist() throws InterruptedException {
8585
var getRequest = GetOrderInput.builder().id(UUID.randomUUID().toString()).build();
8686
var orderNotFound = assertThrows(OrderNotFound.class, () -> client.getOrder(getRequest));
87-
assertEquals(orderNotFound.orderId(), getRequest.id());
87+
assertEquals(orderNotFound.getOrderId(), getRequest.getId());
8888
}
8989

9090
@AfterAll

examples/event-streaming-client/src/it/java/software/amazon/smithy/java/example/eventstreaming/EventStreamTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public void fizzBuzz() throws InterruptedException {
4646

4747
AtomicLong receivedEvents = new AtomicLong();
4848
Set<Long> unbuzzed = new HashSet<>();
49-
output.stream().subscribe(new Flow.Subscriber<>() {
49+
output.getStream().subscribe(new Flow.Subscriber<>() {
5050

5151
private Flow.Subscription subscription;
5252

0 commit comments

Comments
 (0)