Module: Ansible::TransmitController

Defined in:
lib/ansible/transmit_controller.rb

Instance Method Summary collapse

Instance Method Details

#close_connection ⇒ Object 



8
9
10
 
# File 'lib/ansible/transmit_controller.rb', line 8

def close_connection
  response.stream.close
end

#set_headers ⇒ Object 



12
13
14
15
 
# File 'lib/ansible/transmit_controller.rb', line 12

def set_headers
  return if headers['Content-Type'] == 'text/event-stream'
  headers['Content-Type'] = 'text/event-stream'
end

#sse ⇒ Object 



17
18
19
 
# File 'lib/ansible/transmit_controller.rb', line 17

def sse
  @sse ||= SSE.new response.stream
end

#transmit(event, message) ⇒ Object 



3
4
5
6
 
# File 'lib/ansible/transmit_controller.rb', line 3

def transmit(event, message)
  set_headers
  sse.write event, message
end