class_docstr: Listen for HTTP POSTs on given port
  
  Each connection will emit one event, containing the body data of
  the request
  
  Parameters
  ----------
  port : int
      The port to listen on
  path : str
      Specific path to listen on. Can be regex, but content is not used.
  start : bool
      Whether to immediately startup the server. Usually you want to connect
      downstream nodes first, and then call ``.start()``.
  server_kwargs : dict or None
      If given, set of further parameters to pass on to HTTPServer
  
  Examples
  --------
  
  >>> source = Source.from_http_server(4567)  # doctest: +SKIP
class_docstr_tok: ["Listen","for","HTTP","POSTs","on","given","port","Each","connection","will","emit","one","event",",","containing","the","body","data","of","the","request","Parameters","--","--","--","--","--","port",":","int","The","port","to","listen","on","path",":","str","Specific","path","to","listen","on",".","Can","be","regex",",","but","content","is","not","used",".","start",":","bool","Whether","to","immediately","startup","the","server",".","Usually","you","want","to","connect","downstream","nodes","first",",","and","then","call","``",".start","(",")","``",".","server_kwargs",":","dict","or","None","If","given",",","set","of","further","parameters","to","pass","on","to","HTTPServer","Examples","--","--","--","--",">",">",">","source","=","Source.from_http_server","(","4567",")","#","doctest",":","+SKIP"]
code: def run(self):
      from tornado.web import Application, RequestHandler
      from tornado.httpserver import HTTPServer
  
      class Handler(RequestHandler):
          source = self
  
          async def post(self):
              await asyncio.gather(
                  *self.source._emit(self.request.body)
              )
              self.write("OK")
  
      application = Application(
          [
              (self.path, Handler),
          ]
      )
      server = HTTPServer(application, **self.server_kwargs)
      server.listen(self.port)
      self.server = server
  
imports: import asyncio
  from glob import glob
  import queue
  import os
  import time
  from tornado import gen
  import weakref
  from .core import Stream, convert_interval, RefCounter, sync
label_desc: Use image node_id 2 for calling the from_http_server obj's underlying member method code with example usage: obj.run() without return types