diff --git a/omniqueue/src/backends/redis/mod.rs b/omniqueue/src/backends/redis/mod.rs index 62f6480..efa1ef2 100644 --- a/omniqueue/src/backends/redis/mod.rs +++ b/omniqueue/src/backends/redis/mod.rs @@ -205,8 +205,7 @@ fn internal_to_list_payload( ) -> Vec { let id = delayed_key_id(); let num_receives = num_receives.to_string(); - let mut result = - Vec::with_capacity(id.len() + num_receives.as_bytes().len() + payload.len() + 3); + let mut result = Vec::with_capacity(id.len() + num_receives.len() + payload.len() + 3); result.extend(id.as_bytes()); result.push(b'#'); result.extend(num_receives.as_bytes()); diff --git a/omniqueue/tests/it/redis_fallback.rs b/omniqueue/tests/it/redis_fallback.rs index 627d38d..716a696 100644 --- a/omniqueue/tests/it/redis_fallback.rs +++ b/omniqueue/tests/it/redis_fallback.rs @@ -543,7 +543,7 @@ async fn test_backward_compatible() { // Old payload format: let id = svix_ksuid::Ksuid::new(None, None).to_base62(); let org_payload_str = serde_json::to_string(&org_payload).unwrap(); - let mut payload = Vec::with_capacity(id.len() + org_payload_str.as_bytes().len() + 1); + let mut payload = Vec::with_capacity(id.len() + org_payload_str.len() + 1); payload.extend(id.as_bytes()); payload.push(b'|'); payload.extend(org_payload_str.as_bytes());