change observable to use pipe finalize instead of subscribe

change observable to use pipe finalize instead of subscribe #78