Skip to content

Commit

Permalink
Fix the bug where inline subscribers do not receive messages after al…
Browse files Browse the repository at this point in the history
…l non-inline clients unsubscribe. (#386)

Co-authored-by: JB <[email protected]>
  • Loading branch information
werbenhu and mochi-co authored Apr 16, 2024
1 parent cb217cd commit 21491d9
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion topics.go
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,7 @@ func (x *TopicsIndex) seek(filter string, d int) *particle {

// trim removes empty filter particles from the index.
func (x *TopicsIndex) trim(n *particle) {
for n.parent != nil && n.retainPath == "" && n.particles.len()+n.subscriptions.Len()+n.shared.Len() == 0 {
for n.parent != nil && n.retainPath == "" && n.particles.len()+n.subscriptions.Len()+n.shared.Len()+n.inlineSubscriptions.Len() == 0 {
key := n.key
n = n.parent
n.particles.delete(key)
Expand Down

0 comments on commit 21491d9

Please sign in to comment.