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