From 80da1709952b27f4db8cad0bc4588b4103aaa46b Mon Sep 17 00:00:00 2001
From: wanghui <wh_linux@126.com>
Date: Tue, 26 Oct 2021 14:19:12 +0800
Subject: [PATCH] fix skipped event doesn't ack

This is a issue that first created as #391 and fixed by #412, and it
seems the commit 5731acdc6b0ceee9e06da32f5c3394e659cb080c had toke
the issue back.
---
 faust/streams.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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