Fixed impl for explicit authorize on actionAuth msg received

ably · Sep 2, 2024 · 947de24 · 947de24
1 parent 9bea0c0
commit 947de24
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/ably/realtime_conn.go b/ably/realtime_conn.go
@@ -893,9 +893,10 @@ func (c *Connection) eventloop() {
 			if c.conn != nil {
 				c.conn.Close()
 			}
-		case actionAuth:
-			// RTN22
-			c.auth.Authorize(context.Background(), c.auth.params)
+		case actionAuth: // RTN22
+			canceledCtx, cancel := context.WithCancel(context.Background())
+			cancel() // Cancel context to unblock current eventloop to receieve new messages
+			c.auth.Authorize(canceledCtx, c.auth.params)
 		default:
 			c.callbacks.onChannelMsg(msg)
 		}