Merge pull request #455 from ocoanet/master

Use Util.getSequencesFor to create sequences from processors
LMAX-Exchange · Jul 5, 2023 · b29b8fd · b29b8fd
2 parents 87156a0 + f164d9f
commit b29b8fd
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/src/main/java/com/lmax/disruptor/dsl/Disruptor.java b/src/main/java/com/lmax/disruptor/dsl/Disruptor.java
@@ -195,15 +195,11 @@ public EventHandlerGroup<T> handleEventsWith(final EventProcessor... processors)
             consumerRepository.add(processor);
         }
 
-        final Sequence[] sequences = new Sequence[processors.length];
-        for (int i = 0; i < processors.length; i++)
-        {
-            sequences[i] = processors[i].getSequence();
-        }
+        final Sequence[] sequences = Util.getSequencesFor(processors);
 
         ringBuffer.addGatingSequences(sequences);
 
-        return new EventHandlerGroup<>(this, consumerRepository, Util.getSequencesFor(processors));
+        return new EventHandlerGroup<>(this, consumerRepository, sequences);
     }