package org.helioviewer.jhv.plugins.swek.sources.comesep;

import java.util.LinkedList;
import java.util.Queue;

import org.helioviewer.jhv.data.datatype.event.JHVEvent;
import org.helioviewer.jhv.plugins.swek.sources.SWEKEventStream;

public class ComesepEventStream implements SWEKEventStream {

    /** Queue with events */
    Queue<JHVEvent> eventQueue = new LinkedList<JHVEvent>();

    public ComesepEventStream() {
        eventQueue = new LinkedList<JHVEvent>();
    }

    @Override
    public boolean hasEvents() {
        return !eventQueue.isEmpty();
    }

    @Override
    public JHVEvent next() {
        return eventQueue.poll();
    }

    @Override
    public boolean additionalDownloadNeeded() {
        return false;
    }

    public void addJHVEvent(ComesepEvent currentEvent) {
        eventQueue.add(currentEvent);
    }

}

package org.helioviewer.jhv.plugins.swek.sources.comesep;

public class ComesepEventStream {

}

--- 
+++ 
@@ -1,5 +1,37 @@
 package org.helioviewer.jhv.plugins.swek.sources.comesep;
 
-public class ComesepEventStream {
+import java.util.LinkedList;
+import java.util.Queue;
+
+import org.helioviewer.jhv.data.datatype.event.JHVEvent;
+import org.helioviewer.jhv.plugins.swek.sources.SWEKEventStream;
+
+public class ComesepEventStream implements SWEKEventStream {
+
+    /** Queue with events */
+    Queue<JHVEvent> eventQueue = new LinkedList<JHVEvent>();
+
+    public ComesepEventStream() {
+        eventQueue = new LinkedList<JHVEvent>();
+    }
+
+    @Override
+    public boolean hasEvents() {
+        return !eventQueue.isEmpty();
+    }
+
+    @Override
+    public JHVEvent next() {
+        return eventQueue.poll();
+    }
+
+    @Override
+    public boolean additionalDownloadNeeded() {
+        return false;
+    }
+
+    public void addJHVEvent(ComesepEvent currentEvent) {
+        eventQueue.add(currentEvent);
+    }
 
 }
Implement the comesep event stream

git-svn-id: 4e353c0944fe8da334633afc35765ef362dec675@2830 b4e469a2-07ce-4b26-9273-4d7d95a670c7
