From 8f35828c849356cf421a110c325c4a2cf8229d80 Mon Sep 17 00:00:00 2001 From: Nekojimi Date: Sun, 21 Apr 2024 16:46:07 +0100 Subject: [PATCH] QueueThing: add ability to request a specific item for processing. --- src/main/java/moe/nekojimi/chords/QueueThing.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/src/main/java/moe/nekojimi/chords/QueueThing.java b/src/main/java/moe/nekojimi/chords/QueueThing.java index 21ea53a..4ab1aba 100644 --- a/src/main/java/moe/nekojimi/chords/QueueThing.java +++ b/src/main/java/moe/nekojimi/chords/QueueThing.java @@ -74,6 +74,18 @@ public abstract class QueueThing implements Consumer } } + public List> requestSpecific(List inputs, Consumer destination) + { + List> ret = new ArrayList<>(); + for (I input : inputs) + { + Promise promise = new Promise<>(input, destination); + ret.add(promise); + handlePromise(promise); + } + return ret; + } + public List> request(int count, Consumer destination) { List> ret = new ArrayList<>();