Method: NATS#flush_pending

Defined in:
lib/nats/client.rb

#flush_pending ⇒ Object

:nodoc:



866
867
868
869
870
 
# File 'lib/nats/client.rb', line 866

def flush_pending #:nodoc:
  return unless @pending
  send_data(@pending.join)
  @pending, @pending_size = nil, 0
end