Update pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/imp…

…l/PersistentTopicsBase.java thenAccept is better than thenCompose. Co-authored-by: lipenghui <[email protected]>
apache · Jan 29, 2022 · 759504d · 759504d
1 parent 768ce72
commit 759504d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -2526,7 +2526,7 @@ protected void internalPeekNthMessage(AsyncResponse asyncResponse, String subNam
                     }
                     return entry;
                 })
-                .thenCompose(entry -> {
+                .thenAccept(entry -> {
                     if (entry != null) {
                         try {
                             Response response = generateResponseWithEntry(entry);