def parse(self, stream_info):
        with stream_info.open() as f:
            return self.parse_file(f)
Replaces the trajectory's service with a queue sender and starts the queue process.
dataset/ETHPy150Open cjerdonek/open-rcv/openrcv/parsing.py/Parser.parse--crossover with--dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py/MultiprocContext._prepare_netqueue