1 files changed, 10 insertions, 0 deletions
diff --git a/src/mining/Stream.java b/src/mining/Stream.java
index 36fba1b..1822bc2 100644
--- a/src/mining/Stream.java
+++ b/src/mining/Stream.java
@@ -1,6 +1,7 @@
 package mining;
 
 import java.io.IOException;
+import java.util.Set;
 
 /**
  * Provides access to a stream. The implementor is supposed to provide means
@@ -44,4 +45,13 @@ public interface Stream {
      * @return true if connection can be made, false otherwise.
      */
     public boolean isValid();
+
+    /**
+     * Determine keywords for the search query.
+     *
+     * @param active true to return keywords actually in use, false to return
+     * keywords that are queued for the next iteration.
+     * @return A list of keywords, possibly empty if there are none.
+     */
+    public Set<String> getKeywords(boolean active);
 }