From f0a6f3dcf8a3cd2e3ddd32fb4f540521e7cfba7f Mon Sep 17 00:00:00 2001 From: sacOO7 Date: Thu, 12 Sep 2024 11:31:09 +0530 Subject: [PATCH] Added missing spec annotations for RTL11 --- ably/realtime_client.go | 2 +- ably/realtime_presence.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ably/realtime_client.go b/ably/realtime_client.go index 56de739a..c37125ae 100644 --- a/ably/realtime_client.go +++ b/ably/realtime_client.go @@ -89,7 +89,7 @@ func (c *Realtime) onChannelMsg(msg *protocolMessage) { func (c *Realtime) onReconnected(failedResumeOrRecover bool) { for _, ch := range c.Channels.Iterate() { switch ch.State() { - // RTN15g3, RTN15c6, RTN15c7, RTN16l + // RTN15g3, RTN15c6, RTN15c7, RTN16l, RTL3d case ChannelStateAttaching, ChannelStateAttached, ChannelStateSuspended: ch.mayAttach(false) case ChannelStateDetaching: //RTN19b diff --git a/ably/realtime_presence.go b/ably/realtime_presence.go index e93192bd..c7f8be16 100644 --- a/ably/realtime_presence.go +++ b/ably/realtime_presence.go @@ -57,7 +57,7 @@ func (pres *RealtimePresence) isValidChannelState() error { } } -// RTP5a +// RTP5a, RTP16b, RTL11 func (pres *RealtimePresence) onChannelDetachedOrFailed(err error) { for k := range pres.members { delete(pres.members, k) @@ -68,7 +68,7 @@ func (pres *RealtimePresence) onChannelDetachedOrFailed(err error) { pres.queue.Fail(err) } -// RTP5f, RTP16b +// RTP5f, RTP16b, RTL11 func (pres *RealtimePresence) onChannelSuspended(err error) { pres.queue.Fail(err) }