core/lib/gaku/streamer/sse.rb in gaku-0.1.1 vs core/lib/gaku/streamer/sse.rb in gaku-0.2.0
- old
+ new
@@ -1,16 +1,16 @@
-#change SSE.new with rails SSE object when is released
-#https://github.com/rails/rails/blob/master/actionpack/lib/action_controller/metal/live.rb
+# change SSE.new with rails SSE object when is released
+# https://github.com/rails/rails/blob/master/actionpack/lib/action_controller/metal/live.rb
require 'json'
module Streamer
class SSE
- def initialize io
+ def initialize(io)
@io = io
end
- def write object, options = {}
- options.each do |k,v|
+ def write(object, options = {})
+ options.each do |k, v|
@io.write "#{k}: #{v}\n"
end
@io.write "data: #{object}\n\n"
end