From a0427209d8e73c1006aa3cce406d5f17b2f72cef Mon Sep 17 00:00:00 2001 From: Brian Clozel Date: Wed, 18 Jan 2017 22:30:28 +0100 Subject: [PATCH] Upgrade to Reactor Aluminium SNAPSHOT --- build.gradle | 2 +- .../http/server/reactive/AsyncIntegrationTests.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/build.gradle b/build.gradle index b02e67fc0a8..1d722f81cda 100644 --- a/build.gradle +++ b/build.gradle @@ -79,7 +79,7 @@ configure(allprojects) { project -> ext.poiVersion = "3.15" ext.protobufVersion = "3.1.0" ext.quartzVersion = "2.2.3" - ext.reactorVersion = "Aluminium-RELEASE" + ext.reactorVersion = "Aluminium-BUILD-SNAPSHOT" ext.romeVersion = "1.7.0" ext.rxjavaVersion = '1.2.5' ext.rxjavaAdapterVersion = '1.2.1' diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java b/spring-web/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java index 587a820e8f9..44f639fb429 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java @@ -63,7 +63,7 @@ public class AsyncIntegrationTests extends AbstractHttpHandlerIntegrationTests { @Override public Mono handle(ServerHttpRequest request, ServerHttpResponse response) { return response.writeWith(Flux.just("h", "e", "l", "l", "o") - .delay(Duration.ofMillis(100)) + .delayElements(Duration.ofMillis(100)) .publishOn(asyncGroup) .collect(dataBufferFactory::allocateBuffer, (buffer, str) -> buffer.write(str.getBytes()))); }