Skip to content

Commit

Permalink
Added missing spec annotations for RTL11
Browse files Browse the repository at this point in the history
  • Loading branch information
sacOO7 committed Sep 12, 2024
1 parent 523cd04 commit f0a6f3d
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion ably/realtime_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions ably/realtime_presence.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand All @@ -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)
}
Expand Down

0 comments on commit f0a6f3d

Please sign in to comment.