next(self._msg_iter)
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'])
# add two interrupters, set one of them
interrupter1 = bt2.Interrupter()
return next(self._msg_iter)
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'])
graph = self._graph
up = self._graph.add_component(MySource, 'down')
comp_self._at += 1
def _user_graph_is_configured(self):
- self._msg_iter = self._create_input_port_message_iterator(
- self._input_port
- )
+ self._msg_iter = self._create_message_iterator(self._input_port)
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
comp_self._at += 1
def _user_graph_is_configured(self):
- self._msg_iter = self._create_input_port_message_iterator(
- self._input_port
- )
+ self._msg_iter = self._create_message_iterator(self._input_port)
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
comp_self._at += 1
def _user_graph_is_configured(self):
- self._msg_iter = self._create_input_port_message_iterator(
- self._input_port
- )
+ self._msg_iter = self._create_message_iterator(self._input_port)
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')