Searched defs:read_up_to (Results 1 – 3 of 3) sorted by relevance
133 def read_up_to(self, queue, num_records, name=None): member in ParallelReader
173 def read_up_to(self, queue, num_records, # pylint: disable=invalid-name member in ReaderBase
240 auto read_up_to = in TEST() local