gunli commented on PR #1055: URL: https://github.com/apache/pulsar-client-go/pull/1055#issuecomment-1635730708
> we still need to wait for the channel and block the user goroutine. @Gleiphir2769 I think if we set `blockIfQueueFull`, block the user gorouting is unavoidable, we can use the extra channel to block, if the extra channel is full, it will be blocked automically. > And it also introduces more complexity. So in #1043 I said a fixed length pendingQueue may be not a good idea, if we introduce a dynamic length queue, we can use the dataChan to implement the `blockIfQueueFull` semantics(block if dataChan is full), but the `maxpengingMessage` semantics will be inaccurate, but the error won't be very large. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
