Fixes rebuild bug

apache · Mar 20, 2015 · 5889a3b · 5889a3b
1 parent c7e3459
commit 5889a3b
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java
@@ -101,10 +101,8 @@ private void doWalkCollections(
             edgeType = CpNamingUtils.getEdgeTypeFromCollectionName( collectionName );
         }
 
-        Observable<String> edgeTypes = gm.getEdgeTypesFromSource(
-            new SimpleSearchEdgeType( applicationId, edgeType, null ) );
-
-        edgeTypes.flatMap( emittedEdgeType -> {
+        Observable<Edge> edges = gm.getEdgeTypesFromSource(
+                    new SimpleSearchEdgeType( applicationId, edgeType, null ) ).flatMap( emittedEdgeType -> {
 
             logger.debug( "Loading edges of type {} from node {}", edgeType, applicationId );
 
@@ -136,6 +134,6 @@ private void doWalkCollections(
         }, 100 );
 
         // wait for it to complete
-        edgeTypes.toBlocking().lastOrDefault( null ); // end foreach on edges
+        edges.toBlocking().lastOrDefault( null ); // end foreach on edges
     }
 }