Class: EventHub::Adapters::Test

Inherits:
Object
  • Object
show all
Defined in:
lib/event_hub/adapters/test.rb,
lib/event_hub/adapters/test/message.rb

Defined Under Namespace

Classes: Message

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(config) ⇒ Test

Returns a new instance of Test.



8
9
10
11
 
# File 'lib/event_hub/adapters/test.rb', line 8

def initialize(config)
  @config = config
  @queue = []
end

Instance Attribute Details

#queue ⇒ Object

Returns the value of attribute queue.



6
7
8
 
# File 'lib/event_hub/adapters/test.rb', line 6

def queue
  @queue
end

Instance Method Details

#publish(event) ⇒ Object 



19
20
21
 
# File 'lib/event_hub/adapters/test.rb', line 19

def publish(event)
  @queue << Message.new(event, @queue)
end

#setup_bindings ⇒ Object 



23
24
25
 
# File 'lib/event_hub/adapters/test.rb', line 23

def setup_bindings
  true
end

#subscribe(&block) ⇒ Object 



13
14
15
16
17
 
# File 'lib/event_hub/adapters/test.rb', line 13

def subscribe(&block)
  @queue.each do |message|
    block.call(message)
  end
end