wolfstudy opened a new pull request #712: URL: https://github.com/apache/pulsar-client-go/pull/712
Signed-off-by: xiaolongran <[email protected]> Fixes #711 ### Motivation As #711 desc, when the user calls `Send()`, we introduced **waitgroup** to ensure that the messageID is returned synchronously, but in `internalSendAsync()`, the callback may be triggered multiple times, causing the issue of #711 ### Modifications - Replace `waitgroup` with `doneCh`, consistent with the implementation on the consumer side to facilitate subsequent code maintenance - Introduce an atomic variable isDone to ensure that `close(channel)` will only be triggered once -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
