Searched refs:queue_impl (Results 1 – 1 of 1) sorted by relevance
47 def __init__(self, queue_impl, canceled_flag): argument51 self.queue = queue_impl()218 queue_impl = multiprocessing.Queue229 queue_impl = queue.Queue234 provider = TestProvider(queue_impl, canceled_flag)