self._msgs = [
self._create_stream_beginning_message(stream),
- self._create_stream_activity_beginning_message(stream),
self._create_packet_beginning_message(packet),
event_message,
event_message,
it = graph.create_output_port_message_iterator(src.output_ports['out'])
# Skip beginning messages.
- next(it)
- next(it)
- next(it)
+ msg = next(it)
+ self.assertIsInstance(msg, bt2.message._StreamBeginningMessage)
+ msg = next(it)
+ self.assertIsInstance(msg, bt2.message._PacketBeginningMessage)
msg_ev1 = next(it)
msg_ev2 = next(it)
self._msgs = [
self._create_stream_beginning_message(stream),
- self._create_stream_activity_beginning_message(stream),
self._create_packet_beginning_message(packet),
self._create_event_message(ec, packet),
self._create_event_message(ec, packet),
self._create_packet_end_message(packet),
- self._create_stream_activity_end_message(stream),
self._create_stream_end_message(stream),
]
self._at = 0
msg = next(it)
self.assertIsInstance(msg, bt2.message._StreamBeginningMessage)
msg = next(it)
- self.assertIsInstance(msg, bt2.message._StreamActivityBeginningMessage)
+ self.assertIsInstance(msg, bt2.message._PacketBeginningMessage)
it.seek_beginning()