Class: Messaging::Adapters::Postgres::Streams

Inherits:

Object

Object
Messaging::Adapters::Postgres::Streams

Includes:: Enumerable

Defined in:: lib/messaging/adapters/postgres/streams.rb

Instance Method Summary collapse

Instance Method Details

#[](name) ⇒ `Object`



15
16
17

# File 'lib/messaging/adapters/postgres/streams.rb', line 15

def [](name)
  Stream.new(name)
end

#each ⇒ `Object`

# File 'lib/messaging/adapters/postgres/streams.rb', line 7

def each
  return enum_for(:each) unless block_given?

  all_streams.each do |name|
    yield Stream.new(name)
  end
end