def create_pb_server(self, **kwargs):
        self.port = self.get_free_port()

        listen = 'tcp:%i:interface=localhost'%self.port
        kwargs['listen'] = listen
        kwargs.setdefault('processor', 'pipeline.test_pipeline')
        kwargs.setdefault('wait_for_processor', False)

        self.server = spread_provider.PipedPBService(**kwargs)
        self.server.setServiceParent(self.application)
        self.server.configure(self.runtime_environment)
dataset/ETHPy150Open foundit/Piped/piped/providers/test/test_spread_provider.py/PBTestBase.create_pb_server/original