Contents

# 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)
      @io = io
    end

    def write(object, options = {})
      options.each do |k, v|
        @io.write "#{k}: #{v}\n"
      end
      @io.write "data: #{object}\n\n"
    end

    def close
      @io.close
    end
  end
end

Version data entries

16 entries across 16 versions & 2 rubygems

Version	Path
gaku_core-0.3.0	lib/gaku/streamer/sse.rb
gaku_core-0.3.0.pre.4	lib/gaku/streamer/sse.rb
gaku_core-0.3.0.pre.3	lib/gaku/streamer/sse.rb
gaku_core-0.3.0.pre.2	lib/gaku/streamer/sse.rb
gaku_core-0.3.0.pre.1	lib/gaku/streamer/sse.rb
gaku_core-0.3.0.pre.0	lib/gaku/streamer/sse.rb
gaku-0.2.4	core/lib/gaku/streamer/sse.rb
gaku_core-0.2.4	lib/gaku/streamer/sse.rb
gaku-0.2.3	core/lib/gaku/streamer/sse.rb
gaku_core-0.2.3	lib/gaku/streamer/sse.rb
gaku-0.2.2	core/lib/gaku/streamer/sse.rb
gaku_core-0.2.2	lib/gaku/streamer/sse.rb
gaku-0.2.1	core/lib/gaku/streamer/sse.rb
gaku_core-0.2.1	lib/gaku/streamer/sse.rb
gaku-0.2.0	core/lib/gaku/streamer/sse.rb
gaku_core-0.2.0	lib/gaku/streamer/sse.rb