module Ansible::TransmitController

Public Instance Methods

close_connection() click to toggle source
# File lib/ansible/transmit_controller.rb, line 8
def close_connection
  sse.close
end
set_headers() click to toggle source
# File lib/ansible/transmit_controller.rb, line 16
def set_headers
  return if headers['Content-Type'] == 'text/event-stream'
  headers['Content-Type'] = 'text/event-stream'
end
sse() click to toggle source
# File lib/ansible/transmit_controller.rb, line 21
def sse
  @sse ||= SSE.new response.stream
end
stream_closed?() click to toggle source
# File lib/ansible/transmit_controller.rb, line 12
def stream_closed?
  response.stream.closed?
end
transmit(event, message) click to toggle source
# File lib/ansible/transmit_controller.rb, line 3
def transmit(event, message)
  set_headers
  sse.write event, message unless stream_closed?
end