- self.assertEqual(len(list(msg_iter)), 15)
-
- def test_iter_intersection_subscribe(self):
- specs = [bt2.ComponentSpec('ctf', 'fs', _3EVENTS_INTERSECT_TRACE_PATH)]
- msg_iter = bt2.TraceCollectionMessageIterator(specs, stream_intersection_mode=True,
- message_types=[bt2.EventMessage])
- self.assertEqual(len(list(msg_iter)), 3)
+ msgs = list(msg_iter)
+ self.assertEqual(len(msgs), 19)
+ hist = _count_msgs_by_type(msgs)
+ self.assertEqual(hist[bt2.message._EventMessage], 3)