java - RxJava : cancel event?

Question

是否可以在 RxJava 中取消单个事件？

我的意思是这样的:

final protected PublishSubject<Object> subject = PublishSubject.create();
//...
subject.onNext(object);
//...
subject.cancel(object);

Answer 1

简短回答:

没有。

长答案:

无法取消事件，但可以在适当的时间取消订阅 Observable:

cancelEvents = BehaviourSubject.create();

// ...

subject
    .takeUntil(cancelEvents)
    .subscribe(...)

// ...

cancelEvents.onNext(someEvent);