fix: add the sink to the subscribed map AFTER emitting a subscribe me…

…ssage
ilijaNL · Aug 28, 2020 · 814f46c · 814f46c
1 parent 62155ba
commit 814f46c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/client.ts b/src/client.ts
@@ -252,7 +252,6 @@ export function createClient(options: ClientOptions): Client {
             return;
           }
 
-          subscribedSinks[uuid] = sink;
           messageListener = socky.registerMessageListener(({ data }) => {
             const message = parseMessage(data);
             switch (message.type) {
@@ -285,6 +284,9 @@ export function createClient(options: ClientOptions): Client {
               payload,
             }),
           );
+
+          // the sink is now subscribed
+          subscribedSinks[uuid] = sink;
         })
         .catch(sink.error);