Method: NATS::JetStream::API::StreamCreateResponse#state

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

#state ⇒ StreamState

Returns:



272
273
274
275
276
277
278
279
280
281
282
 
# File 'lib/nats/io/jetstream/api.rb', line 272

StreamCreateResponse = Struct.new(:type, :config, :created, :state, :did_create,
  keyword_init: true) do
  def initialize(opts = {})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    super
    freeze
  end
end