diff options
| author | Ben Culkin <scorpress@gmail.com> | 2023-06-25 15:50:38 -0400 |
|---|---|---|
| committer | Ben Culkin <scorpress@gmail.com> | 2023-06-25 15:50:38 -0400 |
| commit | 44be6e6cd7671dd243056107ffa6201504f7fbce (patch) | |
| tree | ea6d1d0bf5930395c3b79b40b4889782dc1b5791 /src/main/java/bjc/esodata/ComplexSpooler.java | |
| parent | 0f958b08b3446a866418aa485bb60c208d952033 (diff) | |
Update a number of things
Diffstat (limited to 'src/main/java/bjc/esodata/ComplexSpooler.java')
| -rw-r--r-- | src/main/java/bjc/esodata/ComplexSpooler.java | 43 |
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; + } + +} |
