Method: NATS::JetStream::API#stream_seq

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

#stream_seqInteger

Returns The stream sequence.

Returns:

  • (Integer)

    The stream sequence.



31
32
33
34
35
36
37
38
39
40
# File 'lib/nats/io/jetstream/api.rb', line 31

SequenceInfo = Struct.new(:consumer_seq, :stream_seq, :last_active,
                          keyword_init: true) do
  def initialize(opts={})
    # Filter unrecognized fields and freeze.
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
    freeze
  end
end