[GitHub] [pulsar-client-go] yarthur1 commented on a change in pull request #252: [Issue 242][pulsar-client-go] feature: add send timeout

[GitBox <gi...@apache.org>]

yarthur1 commented on a change in pull request #252:
URL: https://github.com/apache/pulsar-client-go/pull/252#discussion_r428423636



##########
File path: pulsar/internal/blocking_queue.go
##########
@@ -131,6 +139,21 @@ func (bq *blockingQueue) Poll() interface{} {
 	return bq.dequeue()
 }
 
+func (bq *blockingQueue) PollIfSatisfy(condition func(interface{}) bool) (item interface{}, empty bool, satisfy bool) {

Review comment:
       Based on your comit,I have modified something,can you check it?
   https://github.com/WJL3333/pulsar-client-go/pull/1
   
   > and there is a new queue in partitionProducer. i use it to check if the sendRequest context is Done. the origin logic in pendingQueue is not changed.
   
   




----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org