updating how piping to observable work