Skip to content

Commit 6f8a6ce

Browse files
committed
perf(session): fix tests after push() return type change
Replace assert!(messages.push(...)) with plain push() calls now that push() returns () instead of bool. Signed-off-by: Sam Betts <1769706+Tehsmash@users.noreply.github.com>
1 parent 150c963 commit 6f8a6ce

1 file changed

Lines changed: 11 additions & 11 deletions

File tree

data-plane/core/session/src/producer_buffer.rs

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -170,32 +170,32 @@ mod tests {
170170
.build_publish()
171171
.unwrap();
172172

173-
assert!(messages.push(p0.clone()));
173+
messages.push(p0.clone());
174174

175175
assert_eq!(messages.get(0).unwrap(), p0);
176176
assert_eq!(messages.get(0).unwrap(), p0);
177177
assert_eq!(messages.get(0).unwrap(), p0);
178178
assert_eq!(messages.get(1), None);
179179

180-
assert!(messages.push(p0.clone()));
181-
assert!(messages.push(p1.clone()));
182-
assert!(messages.push(p2.clone()));
180+
messages.push(p0.clone());
181+
messages.push(p1.clone());
182+
messages.push(p2.clone());
183183

184184
assert_eq!(messages.get(0).unwrap(), p0);
185185
assert_eq!(messages.get(1).unwrap(), p1);
186186
assert_eq!(messages.get(2).unwrap(), p2);
187187
assert_eq!(messages.get(3), None);
188188

189189
// now the messages is full, add a new element will remote the elem 0
190-
assert!(messages.push(p3.clone()));
190+
messages.push(p3.clone());
191191
assert_eq!(messages.get(0), None);
192192
assert_eq!(messages.get(1).unwrap(), p1);
193193
assert_eq!(messages.get(2).unwrap(), p2);
194194
assert_eq!(messages.get(3).unwrap(), p3);
195195
assert_eq!(messages.get(4), None);
196196

197197
// now the messages is full, add a new element will remote the elem 1
198-
assert!(messages.push(p4.clone()));
198+
messages.push(p4.clone());
199199
assert_eq!(messages.get(0), None);
200200
assert_eq!(messages.get(1), None);
201201
assert_eq!(messages.get(2).unwrap(), p2);
@@ -211,11 +211,11 @@ mod tests {
211211
assert_eq!(messages.get(4), None);
212212

213213
// add all msgs and check again
214-
assert!(messages.push(p0.clone()));
215-
assert!(messages.push(p1.clone()));
216-
assert!(messages.push(p2.clone()));
217-
assert!(messages.push(p3.clone()));
218-
assert!(messages.push(p4.clone()));
214+
messages.push(p0.clone());
215+
messages.push(p1.clone());
216+
messages.push(p2.clone());
217+
messages.push(p3.clone());
218+
messages.push(p4.clone());
219219
assert_eq!(messages.get(0), None);
220220
assert_eq!(messages.get(1), None);
221221
assert_eq!(messages.get(2).unwrap(), p2);

0 commit comments

Comments
 (0)