| 213 | } |
| 214 | |
| 215 | async fn assert_reply(last_id: &str, event: &str, b: &[u8]) -> String { |
| 216 | let srr: StreamReadReply = redis::cmd("XREAD") |
| 217 | .arg("COUNT") |
| 218 | .arg(1_usize) |
| 219 | .arg("STREAMS") |
| 220 | .arg("device:stream:event") |
| 221 | .arg(last_id) |
| 222 | .query_async(&mut get_async_redis_conn().await.unwrap()) |
| 223 | .await |
| 224 | .unwrap(); |
| 225 | assert_eq!(1, srr.keys.len()); |
| 226 | |
| 227 | let stream_key = &srr.keys[0]; |
| 228 | assert_eq!(1, stream_key.ids.len()); |
| 229 | let stream_id = &stream_key.ids[0]; |
| 230 | |
| 231 | let v = stream_id.map.get(event).unwrap(); |
| 232 | assert_eq!(&redis::Value::BulkString(b.to_vec()), v); |
| 233 | |
| 234 | stream_id.id.clone() |
| 235 | } |
| 236 | } |