Searched refs:BufferStream (Results 1 – 3 of 3) sorted by relevance
22 from acts.controllers.monsoon_lib.sampling.engine.assembly_line import BufferStream104 transform_buffer = mock.Mock(side_effect=[BufferStream.END])118 side_effect=[expected_buffer, BufferStream.END])133 side_effect=[buffer, buffer, buffer, BufferStream.END])147 transform_buffer = mock.Mock(side_effect=[BufferStream.END])202 input_stream.remove_indexed_buffer.side_effect = [BufferStream.END]213 input_stream.remove_indexed_buffer.side_effect = [BufferStream.END]228 input_stream.remove_indexed_buffer.side_effect = [BufferStream.END]239 input_stream.remove_indexed_buffer.side_effect = [BufferStream.END]253 IndexedBuffer(expected_index, []), BufferStream.END
20 from acts.controllers.monsoon_lib.sampling.engine.assembly_line import BufferStream135 if buffer is BufferStream.END:162 if indexed_buffer is BufferStream.END:
191 stream = BufferStream(self.__generate_queue())262 class BufferStream(object): class311 class DevNullBufferStream(BufferStream):