Class: Pubsubstub::StreamAction

Inherits:

Action

• Object
• Sinatra::Base
• Action
• Pubsubstub::StreamAction

Includes:

Logging

Defined in:

lib/pubsubstub/stream_action.rb

Instance Method Summary

• #call ⇒ Object
• #initialize ⇒ StreamAction constructor

  A new instance of StreamAction.

Methods included from Logging

#debug, #error, #info

Constructor Details

#initialize ⇒ StreamAction

Returns a new instance of StreamAction.

# File 'lib/pubsubstub/stream_action.rb', line 5

def initialize(*)
  super
  @subscriptions = Set.new
  @mutex = Mutex.new
end

Instance Method Details

#call ⇒ Object

# File 'lib/pubsubstub/stream_action.rb', line 26

def call(*)
  spawn_helper_threads
  super
end