def _receive(self, msg):
        message = DataMessage(msg)

        try:
            # this is the real work we want to do
            curi = self._processing(message.curi)
            message.curi = curi
        except:
            # catch any uncaught exception and only log it as CRITICAL
            self._logger.critical(
                    "worker::Uncaught exception executing the worker for URL %s!" %
                    (message.curi.url,))
            self._logger.critical("worker::%s" % (traceback.format_exc(),))

        # finished, now send the result back to the master
        self._out_stream.send_multipart(message.serialize())
Gets resource as stream.
dataset/ETHPy150Open retresco/Spyder/src/spyder/core/worker.py/ZmqWorker._receive--crossover with--dataset/ETHPy150Open rwl/muntjac/muntjac/terminal/class_resource.py/ClassResource.getStream