Skip to content

Commit fc0841c

Browse files
committed
Adapt to method name change in Mono
1 parent 0702898 commit fc0841c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

spring-web/src/test/java/org/springframework/http/server/reactive/RandomHandlerIntegrationTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response)
8484
Mono<Integer> requestSizeMono = request.getBody().
8585
reduce(0, (integer, dataBuffer) -> integer +
8686
dataBuffer.readableByteCount()).
87-
doAfterTerminate((size, throwable) -> {
87+
doOnSuccessOrError((size, throwable) -> {
8888
assertNull(throwable);
8989
assertEquals(REQUEST_SIZE, (long) size);
9090
});

spring-webflux/src/test/java/org/springframework/web/reactive/socket/WebSocketIntegrationTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public void echo() throws Exception {
7373
.subscribeWith(output)
7474
.doOnNext(s -> logger.debug("inbound " + s))
7575
.then()
76-
.doOnTerminate((aVoid, ex) ->
76+
.doOnSuccessOrError((aVoid, ex) ->
7777
logger.debug("Done with " + (ex != null ? ex.getMessage() : "success")));
7878
})
7979
.block(Duration.ofMillis(5000));

0 commit comments

Comments
 (0)