Release queue stream manager when closing session (#135)

vasac · web-flow · commit 6550000af18e · 2025-06-05T07:37:35.000+08:00
diff --git a/coherence/session.go b/coherence/session.go
@@ -444,6 +444,9 @@ func (s *Session) Close() {
 
 		if s.GetProtocolVersion() > 0 {
 			_ = s.v1StreamManagerCache.eventStream.grpcStream.CloseSend()
+			if s.v1StreamManagerQueue != nil {
+				_ = s.v1StreamManagerQueue.eventStream.grpcStream.CloseSend()
+			}
 		}
 		s.dispatch(Closed, func() SessionLifecycleEvent {
 			return newSessionLifecycleEvent(s, Closed)

Original file line number	Diff line number	Diff line change
`@@ -444,6 +444,9 @@ func (s *Session) Close() {`
`444`	`444`
`445`	`445`	`if s.GetProtocolVersion() > 0 {`
`446`	`446`	`_ = s.v1StreamManagerCache.eventStream.grpcStream.CloseSend()`
	`447`	`+ if s.v1StreamManagerQueue != nil {`
	`448`	`+ _ = s.v1StreamManagerQueue.eventStream.grpcStream.CloseSend()`
	`449`	`+ }`
`447`	`450`	`}`
`448`	`451`	`s.dispatch(Closed, func() SessionLifecycleEvent {`
`449`	`452`	`return newSessionLifecycleEvent(s, Closed)`