Searched refs:queue_generator (Results 1 – 3 of 3) sorted by relevance
127 def __init__(self, queue_generator, assembly_line_generator): argument137 self._queue_generator = queue_generator151 def queue_generator(self): member in AssemblyLineBuilder216 def __init__(self, queue_generator=queue.Queue): argument217 super().__init__(queue_generator, ThreadAssemblyLine)
169 queue_generator = mock.Mock()170 builder = AssemblyLineBuilder(queue_generator, mock.Mock())177 self.assertEqual(queue_generator(),
37 def queue_generator(rpc): function45 q.get.side_effect = queue_generator(call)