fix test

rekby · rekby · commit b8f3944474a6 · 2024-07-24T18:40:02.000+03:00
diff --git a/internal/topic/topiclistenerinternal/stream_listener.go b/internal/topic/topiclistenerinternal/stream_listener.go
@@ -109,6 +109,9 @@ func (l *streamListener) initVars(sessionIDCounter *atomic.Int64) {
 	l.hasNewMessagesToSend = make(empty.Chan, 1)
 	l.sessions = &topicreadercommon.PartitionSessionStorage{}
 	l.sessionIDCounter = sessionIDCounter
+	if l.cfg == nil {
+		l.cfg = &StreamListenerConfig{}
+	}
 }
 
 func (l *streamListener) initStream(ctx context.Context, client TopicClient) error {

Original file line number	Diff line number	Diff line change
`@@ -109,6 +109,9 @@ func (l streamListener) initVars(sessionIDCounter atomic.Int64) {`
`109`	`109`	`l.hasNewMessagesToSend = make(empty.Chan, 1)`
`110`	`110`	`l.sessions = &topicreadercommon.PartitionSessionStorage{}`
`111`	`111`	`l.sessionIDCounter = sessionIDCounter`
	`112`	`+ if l.cfg == nil {`
	`113`	`+ l.cfg = &StreamListenerConfig{}`
	`114`	`+ }`
`112`	`115`	`}`
`113`	`116`
`114`	`117`	`func (l *streamListener) initStream(ctx context.Context, client TopicClient) error {`