Repository: usergrid Updated Branches: refs/heads/release-2.1.1 f6b61cc35 -> 8014b4f91
Fix variable using within Observable path. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/8014b4f9 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/8014b4f9 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/8014b4f9 Branch: refs/heads/release-2.1.1 Commit: 8014b4f91b7a7f49d76f8fb234007972bd87364b Parents: f6b61cc Author: Michael Russo <[email protected]> Authored: Tue Mar 29 19:00:14 2016 -0700 Committer: Michael Russo <[email protected]> Committed: Tue Mar 29 19:00:14 2016 -0700 ---------------------------------------------------------------------- .../apache/usergrid/persistence/graph/impl/GraphManagerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/8014b4f9/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/GraphManagerImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/GraphManagerImpl.java b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/GraphManagerImpl.java index e865377..e8761f8 100644 --- a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/GraphManagerImpl.java +++ b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/GraphManagerImpl.java @@ -269,7 +269,7 @@ public class GraphManagerImpl implements GraphManager { final Observable<Id> nodeObservable = - Observable.just( inputNode ).map( node -> nodeSerialization.getMaxVersion( scope, inputNode ) ).takeWhile( + Observable.just( inputNode ).map( node -> nodeSerialization.getMaxVersion( scope, node ) ).takeWhile( maxTimestamp -> maxTimestamp.isPresent() ) //map our delete listener
