Merge pull request #188 from jesse-engineer/feat/optimize_dequeueMessage

feat: optimize ch close Judgement

Author: jesse-engineer

server/session/state.go

@@ -148,8 +148,7 @@ func (s *State) dequeueMessage(ctx context.Context) ([]byte, error) {
 	case <-ctx.Done():
 		return nil, ctx.Err()
 	case msg, ok := <-s.sendChan:
-		if msg == nil && !ok {
-			// There are no new messages and the chan has been closed, indicating that the request may need to be terminated.
+		if !ok {
 			return nil, pkg.ErrSendEOF
 		}
 		return msg, nil

transport/transport_test.go

@@ -63,8 +63,7 @@ func (m *mockSessionManager) DequeueMessageForSend(ctx context.Context, sessionI
 	case <-ctx.Done():
 		return nil, ctx.Err()
 	case msg, ok := <-ch:
-		if msg == nil && !ok {
-			// There are no new messages and the chan has been closed, indicating that the request may need to be terminated.
+		if !ok {
 			return nil, pkg.ErrSendEOF
 		}
 		return msg, nil