class Thin::Connection

def process
  @serving ||= nil
  if @serving != :websocket and @request.websocket?
    @serving = :websocket
  end
  if @request.socket_connection?
    @request.env['em.connection'] = self
    @response.persistent!
    @response.async = true
  end
  thin_process
end

def receive_data(data)
  @serving ||= nil
  return thin_receive_data(data) unless @serving == :websocket
  socket_stream.receive(data) if socket_stream
end