pubsub/all: remove unnecessary nil check (#3517)

knbr13 · web-flow · commit eaaf9769c92c · 2025-01-21T11:31:12.000-08:00
diff --git a/pubsub/pubsub.go b/pubsub/pubsub.go
@@ -562,7 +562,7 @@ func (s *Subscription) Receive(ctx context.Context) (_ *Message, err error) {
 				}
 				resultChannel := s.getNextBatch(batchSize)
 				for msgsOrError := range resultChannel {
-					if msgsOrError.msgs != nil && len(msgsOrError.msgs) > 0 {
+					if len(msgsOrError.msgs) > 0 {
 						// messages received from channel
 						s.mu.Lock()
 						s.q = append(s.q, msgsOrError.msgs...)

Original file line number	Diff line number	Diff line change
`@@ -562,7 +562,7 @@ func (s Subscription) Receive(ctx context.Context) (_ Message, err error) {`
`562`	`562`	`}`
`563`	`563`	`resultChannel := s.getNextBatch(batchSize)`
`564`	`564`	`for msgsOrError := range resultChannel {`
`565`		`- if msgsOrError.msgs != nil && len(msgsOrError.msgs) > 0 {`
	`565`	`+ if len(msgsOrError.msgs) > 0 {`
`566`	`566`	`// messages received from channel`
`567`	`567`	`s.mu.Lock()`
`568`	`568`	`s.q = append(s.q, msgsOrError.msgs...)`