I answered my question and it was my misunderstanding of streams. I need to put the de-init and re-init in its own Task block in the stream. Reason why is because putting these two await calls in their own streams lets me continue to emit values without getting blocked, so you see the .inProgress status as soon as it’s sent rather than having to wait for the re-init to complete