fix nil

Signed-off-by: tison <[email protected]>
apache · Oct 24, 2023 · a4944a9 · a4944a9
1 parent 7d25fc7
commit a4944a9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar/message_chunking_test.go b/pulsar/message_chunking_test.go
@@ -24,6 +24,7 @@ import (
 	"math/rand"
 	"net/http"
 	"strings"
+	"sync"
 	"testing"
 	"time"
 
@@ -569,7 +570,8 @@ func sendSingleChunk(p Producer, uuid string, chunkID int, totalChunks int) {
 			callback: func(id MessageID, producerMessage *ProducerMessage, err error) {
 				close(doneCh)
 			},
-			msg: msg,
+			callbackOnce: &sync.Once{},
+			msg:          msg,
 		},
 		uint32(internal.MaxMessageSize),
 	)