Skip to content

Commit 2c7a777

Browse files
author
tomaszw_backbase
committed
LBT-7347
# partitioning batch permission assignment requests
1 parent fa26a55 commit 2c7a777

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -611,7 +611,8 @@ public Mono<BatchProductGroupTask> assignPermissionsBatch(BatchProductGroupTask
611611
"Assigning permissions: %s",
612612
userPermissionsList.stream().map(this::prettyPrintUserAssignedPermissions)
613613
.collect(Collectors.joining(",")));
614-
return assignPermissionsIntegrationApi.batchUpdateUserPermissions(map(userPermissionsList))
614+
return Flux.fromIterable(partitionList(map(userPermissionsList), 1000))
615+
.flatMap(assignPermissionsIntegrationApi::batchUpdateUserPermissions)
615616
.map(r -> batchResponseUtils.checkBatchResponseItem(r, "Permissions Update",
616617
r.getStatus().toString(), r.getResourceId(), r.getErrors()))
617618
.doOnNext(

0 commit comments

Comments
 (0)