0

我有一个用例,我必须从队列中提取请求。当我处理完最后一个请求时,我必须拉一个新请求。看起来我必须使用一个Subject可以帮助我在完成最后一个拉取请求后触发它的事件。我遇到了一个 API PublishSubject,我可以随时在其中继续发布事件,但我需要向主题发送新对象。但我需要用对象类型定义它,然后onNext(<Object>)为下一个事件调用它。我想要的是一个不需要发送任何特定对象并且像通知一样被触发的主题(类似于 onComplete() 的东西)。我怎样才能做到这一点?

4

0 回答 0