Searched refs:threadsafe_generator (Results 1 – 4 of 4) sorted by relevance
116 @data_utils.threadsafe_generator
398 def threadsafe_generator(f): function
92 custom_generator_threads = data_utils.threadsafe_generator(custom_generator)
89 self.iterator_input = data_utils.threadsafe_generator(generator)()