Merge pull request #1 from Tim-Thomas/bugfix/fix_cython_stream_event_in

bugfix: Fix cython stream_event_in to match python impl
Tim-Thomas · Feb 15, 2024 · 36f171a · 36f171a
2 parents 310eb66 + 1745533
commit 36f171a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/faust/_cython/streams.pyx b/faust/_cython/streams.pyx
@@ -179,8 +179,8 @@ cdef class StreamIterator:
                 self.add_unacked(message)
                 self.on_message_in(tp, offset, message)
 
-                stream_state = self.on_stream_event_in(
-                    tp, offset, self.stream, event)
+            stream_state = self.on_stream_event_in(
+                tp, offset, self.stream, event)
             self.stream._set_current_event(event)
             return (event, event.value, stream_state)
         else: