def process(self, message):
        pass
Returns the result when it arrives. If timeout is not None and
dataset/ETHPy150Open ooici/pyon/pyon/ion/streamproc.py/StreamProcess.process--crossover with--dataset/ETHPy150Open serverdensity/sd-agent/checks/libs/thread_pool.py/ApplyResult.get