Fixed - RSearchReactive#dropIndex() method doesn't call onComplete() handler. #5591

redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java

@@ -868,13 +868,13 @@ public interface RedisCommands {
                     new ListFirstObjectDecoder(new EmptyMapConvertor()),
                     new ObjectMapReplayDecoder(true, new CompositeCodec(DoubleCodec.INSTANCE, StringCodec.INSTANCE))));
 
-    RedisStrictCommand<Void> FT_DICTADD = new RedisStrictCommand<>("FT.DICTADD");
-    RedisStrictCommand<Void> FT_DICTDEL = new RedisStrictCommand<>("FT.DICTDEL");
+    RedisStrictCommand<Void> FT_DICTADD = new RedisStrictCommand<>("FT.DICTADD", new VoidReplayConvertor());
+    RedisStrictCommand<Void> FT_DICTDEL = new RedisStrictCommand<>("FT.DICTDEL", new VoidReplayConvertor());
 
     RedisStrictCommand<List<String>> FT_DICTDUMP = new RedisStrictCommand<>("FT.DICTDUMP", new StringListReplayDecoder());
 
-    RedisStrictCommand<Void> FT_DROPINDEX = new RedisStrictCommand<>("FT.DROPINDEX");
-    RedisStrictCommand<Void> FT_CURSOR_DEL = new RedisStrictCommand<>("FT.CURSOR", "DEL");
+    RedisStrictCommand<Void> FT_DROPINDEX = new RedisStrictCommand<>("FT.DROPINDEX", new VoidReplayConvertor());
+    RedisStrictCommand<Void> FT_CURSOR_DEL = new RedisStrictCommand<>("FT.CURSOR", "DEL", new VoidReplayConvertor());
 
     RedisStrictCommand<Map<String, String>> FT_CONFIG_GET = new RedisStrictCommand<>("FT.CONFIG", "GET", new ObjectMapReplayDecoder());
     RedisStrictCommand<Void> FT_CONFIG_SET = new RedisStrictCommand<Void>("FT.CONFIG", "SET", new VoidReplayConvertor());

redisson/src/test/java/org/redisson/RedissonSearchReactiveTest.java

@@ -0,0 +1,31 @@
+package org.redisson;
+
+import org.junit.jupiter.api.Test;
+import org.redisson.api.RSearchReactive;
+import org.redisson.api.search.index.FieldIndex;
+import org.redisson.api.search.index.IndexOptions;
+import org.redisson.api.search.index.IndexType;
+import reactor.test.StepVerifier;
+
+import java.util.Arrays;
+
+public class RedissonSearchReactiveTest extends DockerRedisStackTest {
+
+    @Test
+    public void testDropIndex() {
+        RSearchReactive s = redisson.reactive().getSearch();
+
+        s.createIndex("idx", IndexOptions.defaults()
+                        .on(IndexType.HASH)
+                        .prefix(Arrays.asList("doc:")),
+                FieldIndex.text("t1"),
+                FieldIndex.text("t2"))
+                .as(StepVerifier::create)
+                .verifyComplete();
+
+        s.dropIndex("idx")
+                .as(StepVerifier::create)
+                .verifyComplete();
+    }
+
+}