module ObjectsFramework::PubSub::ClassExtend

Public Instance Methods

publish(channelName) { |channel| ... } click to toggle source
# File lib/objectsframework/pubsub.rb, line 35
def publish(channelName)
        channels = class_variable_get(:@@channels)
        channel = ObjectsFramework::PubSub::Channel.new(channelName)

        Thread.new do
                yield channel
        end

        channels[channelName] = channel

        class_variable_set(:@@channels, channels)
end