.publish can receive null or undefined (#40)

soundxyz · Jul 21, 2023 · 69f7422 · 69f7422
1 parent 5a2ef82
commit 69f7422
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/.changeset/wild-coats-move.md b/.changeset/wild-coats-move.md
@@ -0,0 +1,5 @@
+---
+"@soundxyz/redis-pubsub": minor
+---
+
+.publish can receive null or undefined and it skips the notification
diff --git a/src/index.ts b/src/index.ts
@@ -496,12 +496,14 @@ export function RedisPubSub({
 
     async function publish(
       ...values: [
-        { value: PublishInput; identifier?: string | number },
-        ...{ value: PublishInput; identifier?: string | number }[],
+        { value: PublishInput | null | undefined; identifier?: string | number },
+        ...{ value: PublishInput | null | undefined; identifier?: string | number }[],
       ]
     ) {
       await Promise.all(
         values.map(async ({ value, identifier }) => {
+          if (value == null) return;
+
           const tracing = enabledLogEvents?.PUBLISH_MESSAGE_EXECUTION_TIME ? getTracing() : null;
 
           let parsedValue: ChannelData | SubscriberData;