Fix sync and async testkit backends launch (neo4j#1027)

injectives · injectives · commit 9b3353cc1bb0 · 2021-10-28T15:36:23.000+01:00
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
@@ -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;
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -51,13 +51,13 @@ public TestkitRequestProcessorHandler( BackendMode backendMode )`
`51`	`51`	`switch ( backendMode )`
`52`	`52`	`{`
`53`	`53`	`case ASYNC:`
`54`		`- processorImpl = TestkitRequestProcessorHandler::wrapSyncRequest;`
	`54`	`+ processorImpl = TestkitRequest::processAsync;`
`55`	`55`	`break;`
`56`	`56`	`case REACTIVE:`
`57`	`57`	`processorImpl = ( request, state ) -> request.processRx( state ).toFuture();`
`58`	`58`	`break;`
`59`	`59`	`default:`
`60`		`- processorImpl = TestkitRequest::processAsync;`
	`60`	`+ processorImpl = TestkitRequestProcessorHandler::wrapSyncRequest;`
`61`	`61`	`break;`
`62`	`62`	`}`
`63`	`63`	`}`