fixup! drpcmanager: replace streamBuffer with streamRegistry

shubhamdhama · shubhamdhama · commit a4092e3435fa · 2026-04-01T15:03:47.000+05:30
diff --git a/drpcmanager/manager.go b/drpcmanager/manager.go
@@ -220,7 +220,6 @@ func (m *Manager) terminate(err error) {
 	if m.sigs.term.Set(err) {
 		m.log("TERM", func() string { return fmt.Sprint(err) })
 		m.sigs.tport.Set(m.tr.Close())
-		m.reg.ForEach(func(s *drpcstream.Stream) { s.Close() })
 		m.reg.Close()
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -220,7 +220,6 @@ func (m *Manager) terminate(err error) {`
`220`	`220`	`if m.sigs.term.Set(err) {`
`221`	`221`	`m.log("TERM", func() string { return fmt.Sprint(err) })`
`222`	`222`	`m.sigs.tport.Set(m.tr.Close())`
`223`		`- m.reg.ForEach(func(s *drpcstream.Stream) { s.Close() })`
`224`	`223`	`m.reg.Close()`
`225`	`224`	`}`
`226`	`225`	`}`