You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2015/06/03 18:26:58 UTC
[6/7] incubator-tinkerpop git commit: Add javadoc to EventQueue
related classes.
Add javadoc to EventQueue related classes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/41310d09
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/41310d09
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/41310d09
Branch: refs/heads/master
Commit: 41310d09141c9f5903d4e2cca1a1e70ea253cefd
Parents: 8c5408c
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Wed Jun 3 10:30:59 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Wed Jun 3 12:25:49 2015 -0400
----------------------------------------------------------------------
.../process/traversal/strategy/decoration/EventStrategy.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/41310d09/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
index 530e1aa..3a93f56 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
@@ -97,6 +97,10 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
}
}
+ /**
+ * Gathers messages from callbacks and fires them to listeners. When the event is sent to the listener is
+ * up to the implementation of this interface.
+ */
public interface EventQueue {
/**
* Provide listeners to the queue that were given to the {@link EventStrategy} on construction.
@@ -109,6 +113,9 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
public void addEvent(final Event evt);
}
+ /**
+ * Immediately notifies all listeners as events arrive.
+ */
public static class DefaultEventQueue implements EventQueue {
private List<MutationListener> listeners = Collections.emptyList();