disposing observables
added error and oncomplete to streamtoobservable