You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/09/11 03:28:09 UTC
[38/50] usergrid git commit: change to atomiccount from count()
change to atomiccount from count()
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/2dd90b10
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/2dd90b10
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/2dd90b10
Branch: refs/heads/USERGRID-909
Commit: 2dd90b1050646917a93cee0d0b191bc445c2711a
Parents: e525f7a
Author: Shawn Feldman <sf...@apache.org>
Authored: Wed Sep 9 10:58:20 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Wed Sep 9 10:58:20 2015 -0600
----------------------------------------------------------------------
.../main/java/org/apache/usergrid/rest/ApplicationsResource.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/2dd90b10/stack/rest/src/main/java/org/apache/usergrid/rest/ApplicationsResource.java
----------------------------------------------------------------------
diff --git a/stack/rest/src/main/java/org/apache/usergrid/rest/ApplicationsResource.java b/stack/rest/src/main/java/org/apache/usergrid/rest/ApplicationsResource.java
index 8d36acb..6127efc 100644
--- a/stack/rest/src/main/java/org/apache/usergrid/rest/ApplicationsResource.java
+++ b/stack/rest/src/main/java/org/apache/usergrid/rest/ApplicationsResource.java
@@ -99,8 +99,7 @@ public class ApplicationsResource extends AbstractContextResource {
final AtomicInteger itemsDeleted = new AtomicInteger(0);
try {
management.deleteAllEntities(applicationId, limit)
- .count()
- .doOnNext(count -> itemsDeleted.set(count))
+ .map(id -> itemsDeleted.incrementAndGet())
.doOnNext(count -> {
if( count % 100 == 0 ){
Map<String,Object> map = new LinkedHashMap<>();