如何取消订阅PublishSubject和BehaviorSubject？
在该subjects程序包下，您有诸如PublishSubject和之类的类BehaviorSubject，我想可以将其描述为一些可用的示例Observables。
这些主题如何退订？没有unsubscribe方法，并且调用onCompleted完全结束了Observable，对吗？
问题答案：
同时Subject是an Observable和an
Observer，可以像普通可观察对象一样取消订阅。使主题特别之处在于它是可观察者和观察者之间的桥梁。它可以通过释放观测到的项目，也可以发射新的项目。就像对期货的承诺一样，主体是可观察的对象。
这是主题科的简短说明：
AsyncSubject ：仅发出源Observable的最后一个值
BehaviorSubject ：当观察者订阅时，会发出源Observable的最近发出的项目和所有后续项目。
PublishSubject ：在订阅时发出源Observable的所有后续项。
ReplaySubject ：不管订阅者何时订阅，都会发出源Observable的所有项目。
在官方文档提供了一些好的大理石图这使得它更容易理解
-
我使用SockJS和StompJS，当我在浏览器中打开我的应用程序时，有时它会在连接到websocket之前尝试订阅一些主题。我希望主题订阅等待应用程序连接到websocket。 这就是我实现此代码的原因，我将其称为： 因此，我只在连接状态为时才订阅该主题，并且只有在客户端首次成功连接时才会调用该主题。 我想稍后从主题中取消订阅，所以我需要内部订阅返回的对象，我还需要内部订阅的消息。 我所实现的很
-
考虑一个场景，我们有一个发出字符串的流，我们想将字符串保存在文件中。 我正在使用Publish科目，这很好： 但是，这不起作用（只有被交付） 有没有办法让第二个场景也能正常工作？ i、 例如，我们是否可以更改PublishSubject以确保它缓冲事件，直到订阅者使用它们？ 请注意，BehaviorSubject不是一个选项，因为重新订阅会导致另一个文件保存。它没有“消费事件”的概念。 我找到了U
-
我通读了RxJS文档，并希望确保我理解了< code > subscriber . unsubscribe()和< code > subscriber . complete()之间的区别。 假设我有一个有两个订阅者的可观察对象，订阅者1和订阅者2。如果订阅者1对其订阅调用取消订阅，它将不再接收来自可观察对象的通知，但订阅者2将继续接收它们。 <代码>的文档。complete(): 观察者回调，用于
-
在这篇文章之后，我正在使用带有RxJava/RxKotlin Flowable的Room。我让它运行，但在带有3个片段的ViewPager中使用它存在问题。 我将向您介绍我的代码： 我有一个带有选项卡布局和三个片段（A、B和收藏夹）的视图分页器。前两个片段包含可以添加到收藏夹的数据列表。 在最喜欢的片段中，我使用Flowable来监听A和B所做的更改并相应地更新列表。但是，当一个项目在A和B中成为
-
本文向大家介绍system.reactive 订阅/取消订阅可观察对象(IDisposable)，包括了system.reactive 订阅/取消订阅可观察对象(IDisposable)的使用技巧和注意事项，需要的朋友参考一下 示例 订阅返回IDisposable： 当您准备取消订阅时，只需处置订阅即可：
-
主要内容：一、通知,二、源码分析,三、总结一、通知 在Redis中，既可以实现消息的发送又可以实现订阅，也就是常说的发布/订阅。它的主要逻辑实现在nofigy.c和module.c、pubsub.c中，其实通知做为一种辅助功能，是易用性的一种良好的接口。Redis的通知功能是一种即时在线通知功能，如果CS端断线后，相关的消息就无法再次通知，也就是说，消息机制没有保存和重发功能。这也是为了实现设计上的简单和功能实现的鲁棒性的考虑，至于以后会