diff --git a/testkit-backend/src/main/java/neo4j/org/testkit/backend/channel/handler/TestkitRequestProcessorHandler.java b/testkit-backend/src/main/java/neo4j/org/testkit/backend/channel/handler/TestkitRequestProcessorHandler.java index 83b97b85be..bd5d0352ea 100644 --- a/testkit-backend/src/main/java/neo4j/org/testkit/backend/channel/handler/TestkitRequestProcessorHandler.java +++ b/testkit-backend/src/main/java/neo4j/org/testkit/backend/channel/handler/TestkitRequestProcessorHandler.java @@ -51,13 +51,13 @@ public TestkitRequestProcessorHandler( BackendMode backendMode ) switch ( backendMode ) { case ASYNC: - processorImpl = TestkitRequestProcessorHandler::wrapSyncRequest; + processorImpl = TestkitRequest::processAsync; break; case REACTIVE: processorImpl = ( request, state ) -> request.processRx( state ).toFuture(); break; default: - processorImpl = TestkitRequest::processAsync; + processorImpl = TestkitRequestProcessorHandler::wrapSyncRequest; break; } }