Forcing buffer to only emit batches that contain items.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/19892a9d Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/19892a9d Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/19892a9d Branch: refs/heads/master Commit: 19892a9df867733737b5d06f8f853a5529acffaf Parents: 6b9e5ef Author: George Reyes <g...@apache.org> Authored: Tue Apr 12 20:35:48 2016 -0700 Committer: George Reyes <g...@apache.org> Committed: Tue Apr 12 20:35:48 2016 -0700 ---------------------------------------------------------------------- .../apache/usergrid/corepersistence/index/IndexServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/19892a9d/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexServiceImpl.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexServiceImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexServiceImpl.java index f3f48cc..ad997c8 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexServiceImpl.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexServiceImpl.java @@ -131,7 +131,7 @@ public class IndexServiceImpl implements IndexService { //try to send a whole batch if we can final Observable<IndexOperationMessage> batches = sourceEdgesToIndex - .buffer(250, TimeUnit.MILLISECONDS, indexFig.getIndexBatchSize() ) + .buffer(indexFig.getIndexBatchSize() ) //map into batches based on our buffer size .flatMap( buffer -> Observable.from( buffer )