# File lib/handler/reactor_messaging_adapter.rb, line 149 def add_credit(event) r = event.receiver prefetch = @opts[:prefetch] if r && r.open? && (r.drained == 0) && prefetch && (prefetch > r.credit) r.flow(prefetch - r.credit) end end