Avoid direct concrete instance creation

implementation/src/main/java/io/smallrye/mutiny/helpers/queues/Queues.java

@@ -98,6 +98,17 @@ public static <T> Queue<T> createMpscQueue() {
         return new MpscLinkedQueue<>();
     }
 
+    /**
+     * Creates an unbounded single producer / single consumer queue.
+     *
+     * @param size the chunk size
+     * @return the queue
+     * @param <T> the item type
+     */
+    public static <T> Queue<T> createSpscUnboundedQueue(int size) {
+        return new SpscUnboundedArrayQueue<>(size);
+    }
+
     /**
      * Create a MPSC queue with a given size
      *

implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiCombineLatestOp.java

@@ -10,11 +10,10 @@
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Function;
 
-import org.jctools.queues.SpscUnboundedArrayQueue;
-
 import io.smallrye.mutiny.Context;
 import io.smallrye.mutiny.helpers.ParameterValidation;
 import io.smallrye.mutiny.helpers.Subscriptions;
+import io.smallrye.mutiny.helpers.queues.Queues;
 import io.smallrye.mutiny.infrastructure.Infrastructure;
 import io.smallrye.mutiny.operators.MultiOperator;
 import io.smallrye.mutiny.subscription.ContextSupport;
@@ -78,7 +77,7 @@ private static final class CombineLatestCoordinator<I, O> implements Subscriptio
         private final MultiSubscriber<? super O> downstream;
         private final Function<List<?>, ? extends O> combinator;
         private final List<CombineLatestInnerSubscriber<I>> subscribers = new ArrayList<>();
-        private final SpscUnboundedArrayQueue<Object> queue;
+        private final Queue<Object> queue;
         private final Object[] latest;
         private final boolean delayErrors;
 
@@ -107,7 +106,7 @@ private static final class CombineLatestCoordinator<I, O> implements Subscriptio
                 subscribers.add(new CombineLatestInnerSubscriber<>(context, this, i, bufferSize));
             }
             this.latest = new Object[size];
-            this.queue = new SpscUnboundedArrayQueue<>(bufferSize);
+            this.queue = Queues.createSpscUnboundedQueue(bufferSize);
             this.delayErrors = delayErrors;
         }