File tree Expand file tree Collapse file tree 1 file changed +12
-0
lines changed Expand file tree Collapse file tree 1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -66,6 +66,16 @@ def test_send_and_receive(self):
66
66
data = io .receive ('TestFeed' )
67
67
self .assertEqual (data .value , 'foo' )
68
68
69
+ def test_send_batch_data (self ):
70
+ io = self .get_client ()
71
+ self .ensure_feed_deleted (io , 'TestFeed' )
72
+ feed = Feed (name = "TestFeed" )
73
+ test_feed = aio .create_feed (feed )
74
+ data_list = [Data (value = 'batch' ), Data (value = 'batch' )]
75
+ io .send_batch_data (test_feed .key , 'foo' )
76
+ data = io .receive ('TestFeed' )
77
+ self .assertEqual (data .value , 'batch' )
78
+
69
79
def test_receive_next (self ):
70
80
io = self .get_client ()
71
81
self .ensure_feed_deleted (io , 'TestFeed' )
@@ -108,6 +118,8 @@ def test_data_on_feed_and_data_id_returns_data(self):
108
118
def test_create_data (self ):
109
119
io = self .get_client ()
110
120
self .ensure_feed_deleted (io , 'TestFeed' )
121
+ feed = Feed (name = "TestFeed" )
122
+ test_feed = aio .create_feed (feed )
111
123
io .send_data ('TestFeed' , 1 ) # Make sure TestFeed exists.
112
124
data = Data (value = 42 )
113
125
result = io .create_data ('TestFeed' , data )
You can’t perform that action at this time.
0 commit comments