# File lib/nats/client.rb, line 266 def drain(&blk) if (client and !client.draining? and (client.connected? || client.reconnecting?)) client.drain { blk.call if blk } end end