Searched refs:input_stream (Results 1 – 6 of 6) sorted by relevance
| /tools/test/connectivity/acts/framework/acts/controllers/monsoon_lib/sampling/engine/ |
| D | transformer.py | 40 def transform(self, input_stream): argument
51 input_stream.initialize()
58 self._transform(input_stream)
87 def _on_end_of_stream(self, input_stream): argument
99 def _transform(self, input_stream): argument
159 def _transform(self, input_stream): argument
161 indexed_buffer = input_stream.remove_indexed_buffer()
168 self._on_end_of_stream(input_stream)
198 def _transform(self, input_stream): argument
200 indexed_buffer = input_stream.remove_indexed_buffer()
[all …]
|
| D | assembly_line.py | 50 def __init__(self, transformer=None, input_stream=None): argument
52 self.input_stream = input_stream
88 [node.input_stream])
101 node.input_stream)
155 def source(self, transformer, input_stream=None): argument
171 if input_stream is None:
172 input_stream = DevNullBufferStream()
173 self.nodes.append(AssemblyLine.Node(transformer, input_stream))
|
| /tools/test/connectivity/acts/framework/tests/controllers/monsoon_lib/sampling/engine/ |
| D | transformer_test.py | 71 input_stream = mock.Mock()
77 transformer.transform(input_stream)
80 self.assertTrue(input_stream.initialize.called)
200 input_stream = mock.Mock()
202 input_stream.remove_indexed_buffer.side_effect = [BufferStream.END]
204 sequential_transformer._transform(input_stream)
211 input_stream = mock.Mock()
213 input_stream.remove_indexed_buffer.side_effect = [BufferStream.END]
215 sequential_transformer._transform(input_stream)
226 input_stream = mock.Mock()
[all …]
|
| D | assembly_line_test.py | 60 [node.input_stream])
88 node.input_stream)
109 input_stream = mock.Mock()
112 builder.source(dummy_source, input_stream=input_stream)
114 self.assertEqual(input_stream, builder.nodes[-1].input_stream)
123 self.assertIsInstance(builder.nodes[-1].input_stream,
178 builder.nodes[-1].input_stream._buffer_queue)
|
| /tools/test/connectivity/acts/framework/acts/controllers/monsoon_lib/sampling/lvpm_stock/ |
| D | stock_transformers.py | 50 def _transform(self, input_stream): argument
144 def _transform(self, input_stream): argument
147 .source(PacketReader(), input_stream=input_stream)
206 def _on_end_of_stream(self, input_stream): argument
208 super()._on_end_of_stream(input_stream)
|
| /tools/test/connectivity/acts/framework/acts/controllers/monsoon_lib/sampling/hvpm/ |
| D | transformers.py | 54 def _transform(self, input_stream): argument
167 def _transform(self, input_stream): argument
170 .source(PacketReader(), input_stream=input_stream)
261 def _on_end_of_stream(self, input_stream): argument
263 super()._on_end_of_stream(input_stream)
|