Method: NATS#flush

Defined in:
lib/nats/client.rb

#flush(&blk) ⇒ Object

Flushes all messages and subscriptions for the connection. All messages and subscriptions have been processed by the server when the optional callback is called.



732
733
734
 
# File 'lib/nats/client.rb', line 732

def flush(&blk)
  queue_server_rt(&blk) if blk
end