class Angelo::Base::EventSource

Attributes

responder[R]
socket[R]

Public Class Methods

new(responder) click to toggle source
# File lib/angelo/base.rb, line 425
def initialize responder
  @responder = responder
  @socket = @responder.connection.detach.socket
end

Public Instance Methods

event(name, data = nil) click to toggle source
# File lib/angelo/base.rb, line 430
def event name, data = nil
  @socket.write Base.sse_event(name, data)
end
message(data) click to toggle source
# File lib/angelo/base.rb, line 434
def message data
  @socket.write Base.sse_message(data)
end
on_close(&block) click to toggle source
# File lib/angelo/base.rb, line 438
def on_close &block
  @responder.on_close = block
end
on_close=(block) click to toggle source
# File lib/angelo/base.rb, line 442
def on_close= block
  raise ArgumentError.new unless Proc === block
  @responder.on_close = block
end