class Faye::EventSource

def send(message, options = {})
  return false unless @ready_state == OPEN
  
  message = WebSocket.encode(message.to_s).
            gsub(/(\r\n|\r|\n)/, '\1data: ')
  
  frame  = ""
  frame << "event: #{options[:event]}\r\n" if options[:event]
  frame << "id: #{options[:id]}\r\n" if options[:id]
  frame << "data: #{message}\r\n\r\n"
  
  @stream.write(frame)
  true
end