Class: LocalBus::Publication

Inherits:

Object

• Object
• LocalBus::Publication

Defined in:

lib/local_bus/publication.rb

Overview

Wraps an Async::Barrier and a list of Subscribers that are processing a Message.

Instance Method Summary

• #initialize(barrier, *subscribers) ⇒ Publication constructor

  Constructor.

• #subscribers ⇒ Object

  List of Subscribers that are processing a Message.

• #wait ⇒ Object

  Blocks and waits for the barrier (i.e. all subscribers to complete).

Constructor Details

#initialize(barrier, *subscribers) ⇒ Publication

Constructor

# File 'lib/local_bus/publication.rb', line 9

def initialize(barrier, *subscribers)
  @barrier = barrier
  @subscribers = subscribers
end

Instance Method Details

#subscribers ⇒ Object

Note:

Blocks until all subscribers complete

List of Subscribers that are processing a Message

# File 'lib/local_bus/publication.rb', line 24

def subscribers
  wait
  @subscribers
end

#wait ⇒ Object

Blocks and waits for the barrier (i.e. all subscribers to complete)

# File 'lib/local_bus/publication.rb', line 16

def wait
  @barrier.wait
  self
end