diff --git a/svc/pkg/user-presence/ops/get/src/lib.rs b/svc/pkg/user-presence/ops/get/src/lib.rs index 2d6d84c049..e8ddd6bbe2 100644 --- a/svc/pkg/user-presence/ops/get/src/lib.rs +++ b/svc/pkg/user-presence/ops/get/src/lib.rs @@ -38,15 +38,18 @@ async fn handle( ); } - pipe.query_async::<_, Vec<( - Option, - Option, - Option, - Option, - Option, - )>>(&mut redis) + pipe.query_async::<_, Vec< + Vec<( + Option, + Option, + Option, + Option, + Option, + )>, + >>(&mut redis) .await? .into_iter() + .flatten() .map( |(user_id, game_id, message, public_metadata, friend_metadata)| { if user_id.is_none() { @@ -87,9 +90,10 @@ async fn handle( ); } - pipe.query_async::<_, Vec<(Option, Option, Option)>>(&mut redis) + pipe.query_async::<_, Vec, Option, Option)>>>(&mut redis) .await? .into_iter() + .flatten() .map(|(user_id, update_ts, status)| { if user_id.is_none() { return GlobalResult::Ok(None);