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

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

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



##########
File path: pulsar/internal/blocking_queue.go
##########
@@ -34,6 +34,11 @@ type BlockingQueue interface {
 	// Poll dequeue one item, return nil if queue is empty
 	Poll() interface{}
 
+	// Poll dequeue one item if the item meets the condition,
+	// return nil,true,false if queue is empty,
+	// return nil,false,false if not satisfy.
+	PollIfSatisfy(i func(item interface{}) bool) (item interface{}, empty bool, satisfy bool)

Review comment:
       This doesn't seem to be related with send timeout




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