+class _TraceCollectionMessageIteratorProxySink(bt2_component._UserSinkComponent):
+ def __init__(self, params, msg_list):
+ assert type(msg_list) is list
+ self._msg_list = msg_list
+ self._add_input_port('in')
+
+ def _user_graph_is_configured(self):
+ self._msg_iter = self._create_input_port_message_iterator(
+ self._input_ports['in']
+ )
+
+ def _user_consume(self):
+ assert self._msg_list[0] is None
+ self._msg_list[0] = next(self._msg_iter)
+
+