[iliya-vidrush]

Summary

• Unsubscribe shortened bus.subscribers[t] through the range loop variable, so the result was never written back — channels from Subscribe were never removed and kept receiving events.
• Store slices.DeleteFunc back into the map, which also replaces the backward index loops used to delete in place.
• Behavior change: Publish now stops delivering to typed channels after Unsubscribe.

Validation

• go build ./..., go vet ./pkg/bus/..., and go test ./pkg/bus/... pass.

Flow

%%{init: {'themeVariables': {'fontSize': '12px'}}}%%
flowchart TB
  classDef added fill:#dcfce7,stroke:#16a34a,color:#166534
  classDef changed fill:#fef3c7,stroke:#d97706,color:#92400e
  classDef removed fill:#fee2e2,stroke:#dc2626,color:#991b1b

  unsub["bus.Unsubscribe(ch)"] --> all["slices.DeleteFunc(bus.all, isTarget)"]
  unsub ==>|"result stored in the map"| subs["bus.subscribers[t] = slices.DeleteFunc(...)"]
  unsub -.->|"wrote to the loop copy"| loopvar["channels = append(channels[:i], ...)"]
  subs --> publish["bus.Publish(event)"]
  all --> publish

  class subs added
  class all changed
  class loopvar removed

Loading

[AlperSakarya]

Thanks for the fix, @iliya-vidrush. The fix in this PR (removing typed channels on Unsubscribe) is in the community fork, sst-community/sst, through #7013, in sst-community/sst#27 (released in v4.18.0). The fork carries #7013's version of it, which also lets a typed subscription be passed to Unsubscribe.

The fork accepts issues and PRs, if you have other fixes you'd like carried.