diff --git a/faust/streams.py b/faust/streams.py
index 4a2a6b5a0..6a3254bc0 100644
--- a/faust/streams.py
+++ b/faust/streams.py
@@ -905,10 +905,10 @@ async def _py_aiter(self) -> AsyncIterator[T_co]:
                     except Skip:
                         value = skipped_value
 
-                if value is skipped_value:
-                    continue
-                self.events_total += 1
                 try:
+                    if value is skipped_value:
+                        continue
+                    self.events_total += 1
                     yield value
                 finally:
                     self.current_event = None