+ def test_create_user_attributes(self):
+ stream = self._tr.create_stream(self._sc, user_attributes={"salut": 23})
+ self.assertEqual(stream.user_attributes, {"salut": 23})
+ self.assertIs(type(stream.user_attributes), bt2_value.MapValue)
+
+ def test_const_user_attributes(self):
+ stream = utils.get_const_stream_beginning_message().stream
+ self.assertEqual(stream.user_attributes, {"salut": 23})
+ self.assertIs(type(stream.user_attributes), bt2_value._MapValueConst)
+
+ def test_create_invalid_user_attributes(self):
+ with self.assertRaises(TypeError):
+ self._tr.create_stream(self._sc, user_attributes=object())
+
+ def test_create_invalid_user_attributes_value_type(self):
+ with self.assertRaises(TypeError):
+ self._tr.create_stream(self._sc, user_attributes=23)
+