From 174553305b939b16fb6460fad272386a19f9bef7 Mon Sep 17 00:00:00 2001 From: Timothy Thomas Date: Thu, 15 Feb 2024 15:59:17 -0600 Subject: [PATCH] bugfix: Fix cython stream_event_in to match python impl --- faust/_cython/streams.pyx | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/faust/_cython/streams.pyx b/faust/_cython/streams.pyx index 42736c6f6..42e06bc28 100644 --- 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: