Skip to content

Commit

Permalink
[fix] Correct the SendAsync() description (#1066)
Browse files Browse the repository at this point in the history
### Motivation

After #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

(cherry picked from commit 50015d3)
  • Loading branch information
Gleiphir2769 authored and RobertIndie committed Sep 7, 2023
1 parent 191685f commit 60f2908
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions pulsar/producer.go
Original file line number Diff line number Diff line change
Expand Up @@ -224,8 +224,7 @@ type Producer interface {
Send(context.Context, *ProducerMessage) (MessageID, error)

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

0 comments on commit 60f2908

Please sign in to comment.