fix: add missing await for subscribing (#15)

* fix: add missing `await` * fix: remove unwanted async for unsubscribe
adonisjs · Mar 18, 2024 · 6ea60f2 · 6ea60f2
1 parent 950bfc7
commit 6ea60f2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/providers/transmit_provider.ts b/providers/transmit_provider.ts
@@ -38,11 +38,11 @@ export default class TransmitProvider {
       transmit.$createStream(ctx)
     })
 
-    router.post('__transmit/subscribe', (ctx) => {
+    router.post('__transmit/subscribe', async (ctx) => {
       const uid = ctx.request.input('uid')
       const channel = ctx.request.input('channel')
 
-      const success = transmit.$subscribeToChannel(uid, channel, ctx)
+      const success = await transmit.$subscribeToChannel(uid, channel, ctx)
 
       if (!success) {
         return ctx.response.badRequest()