Fix send async comments (#254)

* Fix send async comments Signed-off-by: xiaolong.ran <rxl@apache.org> * fix a little Signed-off-by: xiaolong.ran <rxl@apache.org> * fix a little Signed-off-by: xiaolong.ran <rxl@apache.org> * fix comments Signed-off-by: xiaolong.ran <rxl@apache.org>
apache · May 18, 2020 · 77f0806 · 77f0806
1 parent bc647c6
commit 77f0806
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pulsar/producer.go b/pulsar/producer.go
@@ -128,6 +128,8 @@ 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)
 	// The callback will report back the message being published and
 	// the eventual error in publishing
 	SendAsync(context.Context, *ProducerMessage, func(MessageID, *ProducerMessage, error))