Class: CelluloidPubsub::Registry

Inherits:

Object

• Object
• CelluloidPubsub::Registry

Defined in:

lib/celluloid_pubsub/registry.rb

Overview

class used to register new channels and save them in memory

Class Attribute Summary

• .channels ⇒ Array<String> private

  holds a list of all known channels.

• .messages ⇒ Hash<String, Array<Hash>> private

  holds a list of all messages sent by clients that were not published to a channel because there were no subscribers at that time.

Instance Attribute Summary

• #channels ⇒ Array, Object

Class Attribute Details

.channels ⇒ Array<String>

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

holds a list of all known channels

Returns:

• (Array<String>)

# File 'lib/celluloid_pubsub/registry.rb', line 36

def channels
  @channels ||= []
end

.messages ⇒ Hash<String, Array<Hash>>

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

holds a list of all messages sent by clients that were not published to a channel because there were no subscribers at that time

The keys are the channel names and the values are arrays of messages

Returns:

• (Hash<String, Array<Hash>>)

# File 'lib/celluloid_pubsub/registry.rb', line 27

def messages
  @messages ||= {}
end

Instance Attribute Details

#channels ⇒ Array, Object

Returns:

• (Array) —

  array of channels to which actors have subscribed to

• (Object) —

  the current value of channels

# File 'lib/celluloid_pubsub/registry.rb', line 8

def channels
  @channels
end