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 2017/04/17 15:32:34 UTC

[4/7] tinkerpop git commit: Removed unncessary stream() usage CTR

Removed unncessary stream() usage  CTR


Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/fcb697db
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/fcb697db
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/fcb697db

Branch: refs/heads/tp32
Commit: fcb697dbd910b56a7ff7ae3dbaec153b0281878d
Parents: b537305
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Mon Apr 17 10:29:15 2017 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Mon Apr 17 10:29:15 2017 -0400

----------------------------------------------------------------------
 .../java/org/apache/tinkerpop/gremlin/server/GremlinServer.java    | 2 +-
 .../org/apache/tinkerpop/gremlin/server/op/session/Session.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fcb697db/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/GremlinServer.java
----------------------------------------------------------------------
diff --git a/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/GremlinServer.java b/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/GremlinServer.java
index db1caae..3c7b861 100644
--- a/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/GremlinServer.java
+++ b/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/GremlinServer.java
@@ -301,7 +301,7 @@ public class GremlinServer {
                 logger.warn("Timeout waiting for boss/worker thread pools to shutdown - continuing with shutdown process.");
             }
 
-            serverGremlinExecutor.getGraphManager().getGraphNames().stream().forEach(gName -> {
+            serverGremlinExecutor.getGraphManager().getGraphNames().forEach(gName -> {
                 logger.debug("Closing Graph instance [{}]", gName);
                 try {
                     serverGremlinExecutor.getGraphManager().getGraph(gName).close();

http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/fcb697db/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/op/session/Session.java
----------------------------------------------------------------------
diff --git a/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/op/session/Session.java b/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/op/session/Session.java
index c97a53c..eec0c71 100644
--- a/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/op/session/Session.java
+++ b/gremlin-server/src/main/java/org/apache/tinkerpop/gremlin/server/op/session/Session.java
@@ -193,7 +193,7 @@ public class Session {
 
         if (!force) {
             // when the session is killed open transaction should be rolled back
-            graphManager.getGraphNames().stream().forEach(gName -> {
+            graphManager.getGraphNames().forEach(gName -> {
                 final Graph g = graphManager.getGraph(gName);
                 if (g.features().graph().supportsTransactions()) {
                     // have to execute the rollback in the executor because the transaction is associated with