+
+ def _create_input_port_message_iterator(self, input_port):
+ utils._check_type(input_port, bt2.port._UserComponentInputPort)
+
+ msg_iter_ptr = native_bt.self_component_port_input_message_iterator_create_from_sink_component(
+ self._bt_ptr, input_port._ptr
+ )
+
+ if msg_iter_ptr is None:
+ raise bt2.CreationError('cannot create message iterator object')
+
+ return bt2.message_iterator._UserComponentInputPortMessageIterator(msg_iter_ptr)
+
+ @property
+ def _is_interrupted(self):
+ return bool(native_bt.self_component_sink_is_interrupted(self._bt_ptr))