Method: NATS::JetStream::API#bytes

Defined in:
lib/nats/io/jetstream/api.rb

#bytes ⇒ Integer

Returns:

  • (Integer) 


243
244
245
246
247
248
249
250
251
 
# File 'lib/nats/io/jetstream/api.rb', line 243

StreamState = Struct.new(:messages, :bytes, :first_seq, :first_ts,
                         :last_seq, :last_ts, :consumer_count,
                         keyword_init: true) do
  def initialize(opts={})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
  end
end