code: def comet_view(self, request):
          
          request_id = self.id_for_request(request)
          if not request_id:
              request.write(HttpResponse(403).as_bytes())
              request.finish()
              return
          
          data = {
              'headers': request.headers,
              'arguments': request.arguments,
              'remote_ip': request.remote_ip,
              'request_id': request_id,
          }
          message_kind = 'comet-%s' % (request.method,)
          if request.method == 'POST':
              data['body'] = simplejson.loads(request.body)
              request.write(HttpResponse(201).as_bytes())
              request.finish()
          else:
              self.pending_requests[request_id].append(request)
          self.publish(Message(message_kind, datetime.now(), data))
docs: This is dumb function, it just passes everything it gets into the
          message stream.  Something else in the stream should be responsible
          for asynchronously figuring out what to do with all these messages.