super().__init__(params, obj, logging_level)
is_cc_object = isinstance(
- component_class, (bt2._SourceComponentClass, bt2._FilterComponentClass)
+ component_class,
+ (bt2._SourceComponentClassConst, bt2._FilterComponentClassConst),
)
is_user_cc_type = isinstance(
component_class, bt2_component._UserComponentType
class _TraceCollectionMessageIteratorProxySink(bt2_component._UserSinkComponent):
- def __init__(self, params, msg_list):
+ def __init__(self, config, 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']
- )
+ self._msg_iter = self._create_message_iterator(self._input_ports['in'])
def _user_consume(self):
assert self._msg_list[0] is None