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