summaryrefslogtreecommitdiff
path: root/src/main/java/bjc/esodata/ComplexSpooler.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/bjc/esodata/ComplexSpooler.java')
-rw-r--r--src/main/java/bjc/esodata/ComplexSpooler.java43
1 files changed, 43 insertions, 0 deletions
diff --git a/src/main/java/bjc/esodata/ComplexSpooler.java b/src/main/java/bjc/esodata/ComplexSpooler.java
new file mode 100644
index 0000000..095527a
--- /dev/null
+++ b/src/main/java/bjc/esodata/ComplexSpooler.java
@@ -0,0 +1,43 @@
+package bjc.esodata;
+
+import java.util.*;
+import java.util.function.Consumer;
+
+/**
+ * Implementation of {@link Spooler} which supports a number of additional features.
+ *
+ * @author bjcul
+ *
+ * @param <T> The type of data contained on the spools
+ */
+public class ComplexSpooler<T> implements Spooler<T> {
+ private Queue<Spool<T>> pendingAnonSpools;
+ private Map<String, Queue<Spool<T>>> pendingGroupedSpools;
+
+ private Map<String, Spool<T>> labelledSpools;
+
+ @Override
+ public void registerSpool(Spool<T> spool) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public Consumer<T> getInput() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Iterator<T> getOutput() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Spool<T> getSpool() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+}