Better to use futures for async communication. Broke apart stream update.