We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6d248bf commit ebf66aeCopy full SHA for ebf66ae
faust/_cython/streams.pyx
@@ -179,8 +179,8 @@ cdef class StreamIterator:
179
self.add_unacked(message)
180
self.on_message_in(tp, offset, message)
181
182
- stream_state = self.on_stream_event_in(
183
- tp, offset, self.stream, event)
+ stream_state = self.on_stream_event_in(
+ tp, offset, self.stream, event)
184
self.stream._set_current_event(event)
185
return (event, event.value, stream_state)
186
else:
0 commit comments