avoid queuing pub/sub with direct IO callbacks.

facil-io · Dec 15, 2024 · a580219 · a580219
1 parent b496109
commit a580219
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/fio-stl.h b/fio-stl.h
@@ -39078,7 +39078,7 @@ SFUNC void fio_subscribe FIO_NOOP(fio_subscribe_args_s args) {
   s = fio___subscription_new();
   if (!s)
     goto sub_error;
-  if (!args.queue)
+  if (!args.queue || !args.on_message)
     args.queue = fio_io_queue();
   *s = (fio_subscription_s){
       .replay_since = args.replay_since,

diff --git a/fio-stl/420 pubsub.h b/fio-stl/420 pubsub.h
@@ -1152,7 +1152,7 @@ SFUNC void fio_subscribe FIO_NOOP(fio_subscribe_args_s args) {
   s = fio___subscription_new();
   if (!s)
     goto sub_error;
-  if (!args.queue)
+  if (!args.queue || !args.on_message)
     args.queue = fio_io_queue();
   *s = (fio_subscription_s){
       .replay_since = args.replay_since,