Changed from interval() to intervalMillis()

This commit is contained in:
Arjen Poutsma 2016-07-12 13:25:18 +02:00
parent c2c7e3b596
commit d736245f28
2 changed files with 2 additions and 2 deletions

View File

@ -72,7 +72,7 @@ public class FlushingIntegrationTests extends AbstractHttpHandlerIntegrationTest
@Override
public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) {
Flux<DataBuffer> responseBody = Flux
.interval(50)
.intervalMillis(50)
.map(l -> {
byte[] data = ("data" + l).getBytes();
DataBuffer buffer = response.bufferFactory().allocateBuffer(data.length);

View File

@ -82,7 +82,7 @@ public class RequestMappingIntegrationTests extends AbstractRequestMappingIntegr
@GetMapping("/stream-result")
public Publisher<Long> stringStreamResponseBody() {
return Flux.interval(100).take(5);
return Flux.intervalMillis(100).take(5);
}
}