FMWK-484 Add node activity filter to monitor method (#23)

aerospike · Jul 1, 2024 · ad13e21 · ad13e21
1 parent b2452ba
commit ad13e21
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java b/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java
@@ -418,6 +418,7 @@ private Mono<AsyncIndexTask> dropIndexImpl(Policy policy,
 	private Mono<Void> waitTillComplete(Mono<AsyncIndexTask> asyncIndexTaskMono, InfoPolicy infoPolicy){
 		 return asyncIndexTaskMono.flatMapMany(indexTask ->
 				Flux.fromArray(aerospikeClient.getNodes())
+						.filter(Node::isActive)
 						.flatMap(node -> queryIndexStatus(infoPolicy, indexTask, node)
 								.delayElement(Duration.ofMillis(1000))
 								.repeat()