add publish command for async interface

sewenew · Jul 12, 2022 · ce6673d · ce6673d
1 parent f06ab7a
commit ce6673d
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/sw/redis++/async_redis.h b/src/sw/redis++/async_redis.h
@@ -991,6 +991,11 @@ class AsyncRedis {
         return _command<long long>(fmt::publish, channel, message);
     }
 
+    template <typename Callback>
+    void publish(const StringView &channel, const StringView &message, Callback &&cb) {
+        _callback_fmt_command<long long>(std::forward<Callback>(cb), fmt::publish, channel, message);
+    }
+
     // co_command* are used internally. DO NOT use them.
 
     template <typename Result, typename Callback>

diff --git a/src/sw/redis++/async_redis_cluster.h b/src/sw/redis++/async_redis_cluster.h
@@ -991,6 +991,11 @@ class AsyncRedisCluster {
         return _command<long long>(fmt::publish, channel, message);
     }
 
+    template <typename Callback>
+    void publish(const StringView &channel, const StringView &message, Callback &&cb) {
+        _callback_fmt_command<long long>(std::forward<Callback>(cb), fmt::publish, channel, message);
+    }
+
     // co_command* are used internally. DO NOT use them.
 
     template <typename Result, typename Callback>