Skip to content

Commit d6b07fe

Browse files
Gleiphir2769graysonzeng
authored andcommitted
[fix] Correct the SendAsync() description (apache#1066)
### Motivation After apache#1029 , `eventChan` is split into `dataChan` and `cmdChan`. But the description of `SendAsync()` is not modified. https://github.com/apache/pulsar-client-go/blob/9867c29ca329302e97ddd9c6a99f66853c7f447f/pulsar/producer.go#L226-L231 ### Modifications - Correct the description of SendAsync() description
1 parent 73fec34 commit d6b07fe

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

pulsar/producer.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -224,8 +224,7 @@ type Producer interface {
224224
Send(context.Context, *ProducerMessage) (MessageID, error)
225225

226226
// SendAsync a message in asynchronous mode
227-
// This call is blocked when the `event channel` becomes full (default: 10) or the
228-
// `maxPendingMessages` becomes full (default: 1000)
227+
// This call is blocked when the `maxPendingMessages` becomes full (default: 1000)
229228
// The callback will report back the message being published and
230229
// the eventual error in publishing
231230
SendAsync(context.Context, *ProducerMessage, func(MessageID, *ProducerMessage, error))

0 commit comments

Comments
 (0)