そういう場合は受け取り側をObserverではなく(Observable)->Disposableにしてあげると

これでやりたいこと完全にできた。ありがとう