Method: PulsarSdk::Consumer::Base#flow_if_need

Defined in:
lib/pulsar_sdk/consumer/base.rb

#flow_if_need ⇒ Object 



60
61
62
63
 
# File 'lib/pulsar_sdk/consumer/base.rb', line 60

def flow_if_need
  return if @capacity > 0 && [@prefetch / 2, 1].max.ceil < (@capacity - @fetched)
  flow
end