**Which feature do you think can be improved?** streams need aync lock write,so use tokio to decide the schedule. **How can it be improved?** tokio::sync::mutex **Additional Information** .. **Before raising this feature request** ..