How do you prevent false terminal 'done' emissions in SSE retry flows?