fn reset(&self) -> u8 {
        self.state.swap(NEED_TO_POLL_ALL, Ordering::SeqCst)
    }
Resets current state allowing to poll the stream and wake up wakers.
futures-util/src/stream/stream/flatten_unordered.rs