@@ -95,6 +95,26 @@ def test_send_batch_data(self):
95
95
data = io .receive (test_feed .key )
96
96
self .assertEqual (int (data .value ), 42 )
97
97
98
+ def test_send_group_multiple_data (self ):
99
+ """send_group_multiple_data
100
+ """
101
+ io = self .get_client ()
102
+ self .ensure_group_deleted (io , 'testgroup' )
103
+ self .ensure_feed_deleted (io , 'testfeed1' )
104
+ self .ensure_feed_deleted (io , 'testfeed2' )
105
+ test_group = io .create_group (Group (name = "testgroup" ))
106
+ test_feed1 = io .create_feed (Feed (name = "testfeed1" ), test_group .key )
107
+ test_feed2 = io .create_feed (Feed (name = "testfeed2" ), test_group .key )
108
+ data_list = [GroupFeedData (value = 42 , key = test_feed1 .key ), GroupFeedData (value = 42 , key = test_feed2 .key )]
109
+ io .send_group_multiple_data (test_group .key , data_list )
110
+ data = io .receive (test_feed1 .key )
111
+ self .assertEqual (int (data .value ), 42 )
112
+ data = io .receive (test_feed2 .key )
113
+ self .assertEqual (int (data .value ), 42 )
114
+ self .ensure_feed_deleted (io , 'testfeed1' )
115
+ self .ensure_feed_deleted (io , 'testfeed2' )
116
+ self .ensure_group_deleted (io , 'testgroup' )
117
+
98
118
def test_receive_next (self ):
99
119
"""receive_next
100
120
"""
0 commit comments