findProcessor returns TestCqlPrepareAsyncProcessor

SiyaoIsHiding · SiyaoIsHiding · commit 31c4c04f5341 · 2025-07-15T17:03:09.000-07:00
diff --git a/integration-tests/src/test/java/com/datastax/oss/driver/core/cql/PreparedStatementCancellationIT.java b/integration-tests/src/test/java/com/datastax/oss/driver/core/cql/PreparedStatementCancellationIT.java
@@ -75,13 +75,13 @@ private CompletableFuture<PreparedStatement> toCompletableFuture(CqlSession sess
     return session.prepareAsync(cql).toCompletableFuture();
   }
 
-  private CqlPrepareAsyncProcessor findProcessor(CqlSession session) {
+  private TestCqlPrepareAsyncProcessor findProcessor(CqlSession session) {
 
     DefaultDriverContext context = (DefaultDriverContext) session.getContext();
-    return (CqlPrepareAsyncProcessor)
+    return (TestCqlPrepareAsyncProcessor)
         Iterables.find(
             context.getRequestProcessorRegistry().getProcessors(),
-            Predicates.instanceOf(CqlPrepareAsyncProcessor.class));
+            Predicates.instanceOf(TestCqlPrepareAsyncProcessor.class));
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -75,13 +75,13 @@ private CompletableFuture<PreparedStatement> toCompletableFuture(CqlSession sess`
`75`	`75`	`return session.prepareAsync(cql).toCompletableFuture();`
`76`	`76`	`}`
`77`	`77`
`78`		`- private CqlPrepareAsyncProcessor findProcessor(CqlSession session) {`
	`78`	`+ private TestCqlPrepareAsyncProcessor findProcessor(CqlSession session) {`
`79`	`79`
`80`	`80`	`DefaultDriverContext context = (DefaultDriverContext) session.getContext();`
`81`		`- return (CqlPrepareAsyncProcessor)`
	`81`	`+ return (TestCqlPrepareAsyncProcessor)`
`82`	`82`	`Iterables.find(`
`83`	`83`	`context.getRequestProcessorRegistry().getProcessors(),`
`84`		`- Predicates.instanceOf(CqlPrepareAsyncProcessor.class));`
	`84`	`+ Predicates.instanceOf(TestCqlPrepareAsyncProcessor.class));`
`85`	`85`	`}`
`86`	`86`
`87`	`87`	`@Test`