From dc52d4c31f03621c86f5ede93eee5542b81f625a Mon Sep 17 00:00:00 2001 From: Sebastien Deleuze Date: Tue, 1 Mar 2016 22:07:54 +0100 Subject: [PATCH] Update for latest Reactor Core Snapshot --- .../client/reactive/WebClientIntegrationTests.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/spring-web-reactive/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java index ac4bc368f5..24017c1b8f 100644 --- a/spring-web-reactive/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java @@ -69,7 +69,7 @@ public class WebClientIntegrationTests { TestSubscriber ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValuesWith( + ts.awaitAndAssertNextValuesWith( httpHeaders -> { assertEquals(MediaType.TEXT_PLAIN, httpHeaders.getContentType()); assertEquals(13L, httpHeaders.getContentLength()); @@ -95,7 +95,7 @@ public class WebClientIntegrationTests { TestSubscriber ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValues("Hello Spring!").assertComplete(); + ts.awaitAndAssertNextValues("Hello Spring!").assertComplete(); RecordedRequest request = server.takeRequest(); assertEquals("testvalue", request.getHeader("X-Test-Header")); @@ -116,7 +116,7 @@ public class WebClientIntegrationTests { TestSubscriber> ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValuesWith(new Consumer>() { + ts.awaitAndAssertNextValuesWith(new Consumer>() { @Override public void accept(ResponseEntity response) { assertEquals(200, response.getStatusCode().value()); @@ -143,7 +143,7 @@ public class WebClientIntegrationTests { TestSubscriber ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValuesWith(p -> assertEquals("barbar", p.getBar())).assertComplete(); + ts.awaitAndAssertNextValuesWith(p -> assertEquals("barbar", p.getBar())).assertComplete(); RecordedRequest request = server.takeRequest(); assertEquals("/pojo", request.getPath()); assertEquals("application/json", request.getHeader(HttpHeaders.ACCEPT)); @@ -163,7 +163,7 @@ public class WebClientIntegrationTests { TestSubscriber ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValuesWith( + ts.awaitAndAssertNextValuesWith( p -> assertThat(p.getBar(), Matchers.is("bar1")), p -> assertThat(p.getBar(), Matchers.is("bar2")) ).assertValueCount(2).assertComplete(); @@ -186,7 +186,7 @@ public class WebClientIntegrationTests { TestSubscriber>> ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValuesWith( + ts.awaitAndAssertNextValuesWith( response -> { assertEquals(200, response.getStatusCode().value()); assertEquals(MediaType.APPLICATION_JSON, response.getHeaders().getContentType()); @@ -213,7 +213,7 @@ public class WebClientIntegrationTests { TestSubscriber ts = new TestSubscriber(); result.subscribe(ts); - ts.awaitAndAssertValuesWith(p -> assertEquals("BARBAR", p.getBar())).assertComplete(); + ts.awaitAndAssertNextValuesWith(p -> assertEquals("BARBAR", p.getBar())).assertComplete(); RecordedRequest request = server.takeRequest(); assertEquals("/pojo/capitalize", request.getPath());