File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -854,9 +854,9 @@ impl<T: ReadConnectionProvider + Sync + ?Sized> DatabaseReadOperations for T {
854854 . one ( self . get_connection ( ) )
855855 . await ?
856856 {
857- // Yield n messages starting from the found queue index + 1. Only return messages
858- // that have not been skipped (skipped = false) to handle the edge case where the
859- // last message in a batch is skipped.
857+ // Yield n messages starting from the found queue index + 1. Only return
858+ // messages that have not been skipped (skipped = false) to handle the edge
859+ // case where the last message in a batch is skipped.
860860 Ok ( models:: l1_message:: Entity :: find ( )
861861 . filter (
862862 // We add 1 to the queue index to constrain across block boundaries
You can’t perform that action at this time.
0 commit comments