【发布时间】:2016-12-02 15:30:43
【问题描述】:
是否可以在 RxJava 中取消单个事件?
我的意思是这样的:
final protected PublishSubject<Object> subject = PublishSubject.create();
//...
subject.onNext(object);
//...
subject.cancel(object);
【问题讨论】:
是否可以在 RxJava 中取消单个事件?
我的意思是这样的:
final protected PublishSubject<Object> subject = PublishSubject.create();
//...
subject.onNext(object);
//...
subject.cancel(object);
【问题讨论】:
简答:
没有。
长答案:
无法取消活动,但可以在合适的时间取消订阅Observable:
cancelEvents = BehaviourSubject.create();
// ...
subject
.takeUntil(cancelEvents)
.subscribe(...)
// ...
cancelEvents.onNext(someEvent);
【讨论】: