usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sfeld...@apache.org
Subject [17/36] usergrid git commit: remove rx
Date Thu, 01 Oct 2015 16:27:52 GMT
remove rx


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

Branch: refs/heads/master
Commit: 28919aebea35c027a5b720ebeebb2200c1d214c3
Parents: bdea1ff
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Fri Sep 25 13:47:29 2015 -0600
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Fri Sep 25 13:47:29 2015 -0600

----------------------------------------------------------------------
 .../usergrid/persistence/index/impl/EsIndexProducerImpl.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/28919aeb/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexProducerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexProducerImpl.java
b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexProducerImpl.java
index a2c8663..2b36fc8 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexProducerImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexProducerImpl.java
@@ -132,7 +132,7 @@ public class EsIndexProducerImpl implements IndexProducer {
 
         //now that we've processed them all, ack the futures after our last batch comes through
         final Observable<IndexOperationMessage> processedIndexOperations =
-            requests.lastOrDefault(null).flatMap(lastRequest -> {
+            requests.flatMap(lastRequest -> {
                 if (lastRequest != null) {
                     return Observable.just(batch);
                 } else {


Mime
View raw message