Update for latest Reactor Core Snapshot

This commit is contained in:
Sebastien Deleuze 2016-03-01 22:19:54 +01:00
parent dc52d4c31f
commit 379ce6354e
2 changed files with 4 additions and 2 deletions

View File

@ -17,6 +17,7 @@
package org.springframework.http.server.reactive;
import java.net.URI;
import java.time.Duration;
import org.hamcrest.Matchers;
import org.junit.Test;
@ -65,7 +66,7 @@ public class AsyncIntegrationTests extends AbstractHttpHandlerIntegrationTests {
public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) {
return response.setBody(Fluxion.just("h", "e", "l", "l", "o")
.useTimer(Timer.global())
.delay(1)
.delay(Duration.ofMillis(100))
.dispatchOn(asyncGroup)
.collect(allocator::allocateBuffer,
(buffer, str) -> buffer.write(str.getBytes())));

View File

@ -18,6 +18,7 @@ package org.springframework.web.reactive.method.annotation;
import java.net.URI;
import java.nio.ByteBuffer;
import java.time.Duration;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
@ -491,7 +492,7 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
@RequestMapping("/stream-result")
public Publisher<Long> stringStreamResponseBody() {
return Flux.interval(1).as(Fluxion::from).take(5);
return Flux.interval(Duration.ofSeconds(1)).as(Fluxion::from).take(5);
}
@RequestMapping("/raw-flux")