class Ansible::SSE

Attributes

stream[R]

Public Class Methods

new(stream) click to toggle source
# File lib/ansible/sse.rb, line 7
def initialize(stream)
  @stream = stream
end

Public Instance Methods

close() click to toggle source
# File lib/ansible/sse.rb, line 17
def close
  stream.close
end
write(event, message) click to toggle source
# File lib/ansible/sse.rb, line 11
def write(event, message)
  stream.write "event: #{event}\n"
  stream.write "retry: 1000\n"
  stream.write "data: #{JSON.dump message}\n\n"
end