pulled observable stream structure out of app state