🐛 fix(bug): NATS function hooks

Prismadic · Dec 19, 2023 · 8b0d669 · 8b0d669
1 parent a038878
commit 8b0d669
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -24,7 +24,7 @@ async def on(self, frequency: str = 'default', stream: str = 'default'):
         except TimeoutError:
             _f('fatal', f'could not connect to {self.server}')
     async def off(self):
-        await self.js.unsubscribe()
+        await self.sub.unsubscribe()
         _f('warn', f'unsubscribed from {self.stream}')
         await self.nc.drain()
         _f('warn', f'disconnected from {self.server}')
@@ -62,7 +62,7 @@ async def on(self, frequency: str = 'default', stream: str = 'default', cb=print
                 except json.decoder.JSONDecodeError:
                     _f('fatal','invalid JSON')
     async def off(self):
-        await self.js.unsubscribe()
+        await self.sub.unsubscribe()
         _f('warn', f'unsubscribed from {self.stream}')
         await self.nc.drain()
         _f('warn', f'disconnected from {self.server}')