code: def streamer(frontend, backend):
      
      try:
          context = zmq.Context()
  
          front_pull = context.socket(zmq.PULL)
          front_pull.set_hwm(0)
          front_pull.bind("tcp://*:%d" % frontend)
  
          back_push = context.socket(zmq.PUSH)
          back_push.bind("tcp://*:%d" % backend)
  
          print("streamer started, backend on port : %d\tfrontend on port: %d" % (backend, frontend))
          zmq.proxy(front_pull, back_push)
      except Exception as e:
          print(e)
      finally:
          front_pull.close()
          back_push.close()
          context.term()
docs: Simple push/pull streamer
  
      :param int frontend: fontend zeromq port
      :param int backend: backend zeromq port