raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_output_port('out')
self.assertEqual(port.name, 'out')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_output_port('out')
self.assertEqual(port.name, 'out')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_input_port('in')
self.assertEqual(port.name, 'in')
def test_sink_add_input_port(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_input_port('in')
self.assertEqual(port.name, 'in')
raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
port3 = comp_self._add_input_port('insert')
def test_user_sink_input_ports_getitem(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
port3 = comp_self._add_input_port('insert')
raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
def test_user_sink_input_ports_getitem_invalid_key(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
def test_user_sink_input_ports_len(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
port3 = comp_self._add_input_port('insert')
def test_user_sink_input_ports_iter(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
port3 = comp_self._add_input_port('insert')
port3 = None
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = None
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = None
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
port3 = None
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
def test_gen_sink_input_ports_getitem_invalid_key(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
raise bt2.Stop
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_output_port('clear')
comp_self._add_output_port('print')
comp_self._add_output_port('insert')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
def test_gen_sink_input_ports_len(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
comp_self._add_input_port('print')
comp_self._add_input_port('insert')
port3 = None
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = None
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_output_port('clear')
port2 = comp_self._add_output_port('print')
port3 = None
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
port3 = None
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal port1, port2, port3
port1 = comp_self._add_input_port('clear')
port2 = comp_self._add_input_port('print')
def test_name(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
def _user_consume(self):
def test_connection_none(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
def _user_consume(self):
def test_is_connected_false(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
comp_self._add_input_port('clear')
def _user_consume(self):
def test_self_name(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_input_port('clear')
self.assertEqual(port.name, 'clear')
def test_self_connection_none(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_input_port('clear')
self.assertIsNone(port.connection)
def test_self_is_connected_false(self):
class MySink(bt2._UserSinkComponent):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
port = comp_self._add_input_port('clear')
self.assertFalse(port.is_connected)
raise bt2.Stop
class MySource(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal user_datas
p = comp_self._add_output_port('port1')
raise bt2.Stop
class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal user_datas
p = comp_self._add_output_port('port1')
raise bt2.Stop
class MySink(bt2._UserFilterComponent, message_iterator_class=MyIter):
- def __init__(comp_self, params):
+ def __init__(comp_self, params, obj):
nonlocal user_datas
p = comp_self._add_input_port('port1')