You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/05/07 02:46:26 UTC

[GitHub] [pulsar-client-node] merlimat commented on issue #152: Interruptible Reader.readNext()?

merlimat commented on issue #152:
URL: https://github.com/apache/pulsar-client-node/issues/152#issuecomment-834019615


   One option is to do what we used to do in Python wrapper (before https://github.com/apache/pulsar/pull/5706 was applied). Use a 100millis timeout on the receive to check for interrupted status. 
   
   That won't be possible when receiveQueueSize=0 but it will work in all the other cases. 


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