228: Added unchecked exception

Author: gkatzioura

java/sqlcommenter-java/src/main/java/com/google/cloud/sqlcommenter/r2dbc/ConnectionFactoryAspect.java

@@ -7,7 +7,6 @@
 import org.aspectj.lang.annotation.Aspect;
 import org.reactivestreams.Publisher;
 
-import io.r2dbc.spi.Connection;
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.Operators;
 
@@ -16,11 +15,11 @@ public class ConnectionFactoryAspect {
 
     @Around("execution(* io.r2dbc.spi.ConnectionFactory.create(..)) ")
     public Object beforeSampleCreation(ProceedingJoinPoint joinPoint) throws Throwable {
-        Publisher<? extends Connection> publisher = (Publisher<? extends Connection>) joinPoint.proceed();
+        Object object = joinPoint.proceed();
 
+        @SuppressWarnings("unchecked") Publisher<Object> publisher = (Publisher<Object>) object;
 
         return Mono.from(publisher)
-                   .cast(Object.class)
                    .transform(Operators.liftPublisher((publisher1, coreSubscriber) -> new ConnectionDecorator(coreSubscriber)));
     }