@ -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'
@ -63,7 +63,7 @@ public class AsyncIntegrationTests extends AbstractHttpHandlerIntegrationTests {
@Override
public Mono<Void> 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())));
}