def call_process(self, message, stream_route, stream_id):
        self.process(message)
Handles preprocessing of packet and process work
dataset/ETHPy150Open ooici/pyon/pyon/ion/streamproc.py/StreamProcess.call_process