Merge pull request 'rwfix' (#127 ) from rwfix into master

Reviewed-on: #127
fixup panic
2023-12-20 22:57:32 +03:00 · 2023-12-20 22:56:28 +03:00
1 changed files with 4 additions and 3 deletions
--- a/kgo.go
+++ b/kgo.go
@@ -196,8 +196,10 @@ func (k *Broker) Publish(ctx context.Context, topic string, msg *broker.Message,

 func (k *Broker) publish(ctx context.Context, msgs []*broker.Message, opts ...broker.PublishOption) error {
 	k.RLock()
-	if !k.connected {
-		k.RUnlock()
+	ok := k.connected
+	k.RUnlock()
+
+	if !ok {
 		k.Lock()
 		c, err := k.connect(ctx, k.kopts...)
 		if err != nil {
@@ -208,7 +210,6 @@ func (k *Broker) publish(ctx context.Context, msgs []*broker.Message, opts ...br
 		k.connected = true
 		k.Unlock()
 	}
-	k.RUnlock()

 	options := broker.NewPublishOptions(opts...)
 	records := make([]*kgo.Record, 0, len(msgs))
Author	SHA1	Message	Date
Vasiliy Tolstov	98da69fbe8	Merge pull request 'rwfix' (#127 ) from rwfix into master Some checks failed build / test (push) Failing after 1m27s Details build / lint (push) Failing after 2m45s Details codeql / analyze (go) (push) Failing after 2m41s Details Reviewed-on: #127	2023-12-20 22:57:32 +03:00
Vasiliy Tolstov	d6d2483d8d	fixup panic Some checks failed codeql / analyze (go) (pull_request) Failing after 2m41s Details prbuild / test (pull_request) Failing after 1m28s Details prbuild / lint (pull_request) Failing after 2m37s Details autoapprove / autoapprove (pull_request) Failing after 1m25s Details automerge / automerge (pull_request) Failing after 4s Details dependabot-automerge / automerge (pull_request) Has been skipped Details Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-12-20 22:56:28 +03:00