rxpy如何取消订阅
问题描述:
from rx import Observable, Observer
from rx.subjects import Subject
drive = Observable.from_list(list(range(33))).publish()
s = Subject()
xs = s.buffer_with_count(6).do_action(print)
xs.subscribe(print)
ss = Subject()
xss = ss.buffer_with_count(6).do_action(print)
xss.subscribe()
drive.subscribe(s)
drive.subscribe(ss)
drive.connect()
这是我的代码。
我只找到订阅的方式,但如果我想从驱动器中删除s或ss。
我能做些什么。
问题是如何取消订阅s和ss。rxpy如何取消订阅
答
drive.subscribe(s)
正在退回一次性。拨打dispose()
即取消订阅您的观察员。
d1=drive.subscribe(s)
...
d1.dispose()