@ -84,7 +84,7 @@ public class RandomHandlerIntegrationTests extends AbstractHttpHandlerIntegratio
@@ -84,7 +84,7 @@ public class RandomHandlerIntegrationTests extends AbstractHttpHandlerIntegratio
@ -73,7 +73,7 @@ public class WebSocketIntegrationTests extends AbstractWebSocketIntegrationTests
@@ -73,7 +73,7 @@ public class WebSocketIntegrationTests extends AbstractWebSocketIntegrationTests
.subscribeWith(output)
.doOnNext(s->logger.debug("inbound "+s))
.then()
.doOnTerminate((aVoid,ex)->
.doOnSuccessOrError((aVoid,ex)->
logger.debug("Done with "+(ex!=null?ex.getMessage():"success")));