|
|
@ -106,7 +106,7 @@ public class AsyncIntegrationTests { |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) { |
|
|
|
public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) { |
|
|
|
return response.setBody(Stream.just("h", "e", "l", "l", "o") |
|
|
|
return response.setBody(Stream.just("h", "e", "l", "l", "o") |
|
|
|
.timer(Timer.global()) |
|
|
|
.useTimer(Timer.global()) |
|
|
|
.throttleRequest(100) |
|
|
|
.throttleRequest(100) |
|
|
|
.dispatchOn(asyncGroup) |
|
|
|
.dispatchOn(asyncGroup) |
|
|
|
.collect(allocator::allocateBuffer, |
|
|
|
.collect(allocator::allocateBuffer, |
|
|
|