LineProtocol will parse out newline terminated strings from a receive_data stream

 module Server
   include EM::P::LineProtocol

   def receive_line(line)
     send_data("you said: #{line}")
   end
 end