diff --git a/src/executor/paginator.rs b/src/executor/paginator.rs index 5cbe2b80..6ca07569 100644 --- a/src/executor/paginator.rs +++ b/src/executor/paginator.rs @@ -194,12 +194,8 @@ where /// ``` pub fn into_stream(mut self) -> PinBoxStream<'db, Result, DbErr>> { Box::pin(stream! { - loop { - if let Some(vec) = self.fetch_and_next().await? { - yield Ok(vec); - } else { - break - } + while let Some(vec) = self.fetch_and_next().await? { + yield Ok(vec); } }) }