

def create_recordings_saver(address, model):

    def create_socket():
        context = zmq.Context()
        socket = context.socket(zmq.PULL)
        socket.bind(address)
        return socket
    run_forever = (lambda : True)
    return RecordingsSaver(create_socket, model, model)

dataset/ETHPy150Open UFAL-DSG/cloud-asr/cloudasr/recordings/lib.py create_recordings_saver/VarMisuse@65/78 `run_forever`->`model`