You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2015/10/14 18:54:11 UTC
[15/39] usergrid git commit: remove observable
remove observable
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/407ebe03
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/407ebe03
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/407ebe03
Branch: refs/heads/usergrid-1007-shiro-cache
Commit: 407ebe037beb275c92183b450b0885d2b421a27b
Parents: a5b51c9
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Sep 25 13:35:59 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Sep 25 13:35:59 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/407ebe03/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 ef59abb..9223293 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
@@ -141,7 +141,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 {