RxJava BehaviorSubject没有发射最后一项吗？
RxJava是一个基于观察者模式的异步编程库，它提供了丰富的操作符和线程调度器，用于简化异步编程和处理数据流。在RxJava中，BehaviorSubject是一种特殊的可观察者（Observable），它可以发射最近的一个数据项和后续的数据项给所有订阅者。
对于BehaviorSubject来说，它会在被订阅时立即发射最近的一个数据项（如果有的话），然后继续发射后续的数据项。但是需要注意的是，当BehaviorSubject完成时，它不会再发射最后一项数据。
这意味着，如果在订阅BehaviorSubject之前已经有数据项被发射，订阅者会立即收到最近的数据项。然后，如果在订阅之后有更多的数据项被发射，订阅者也会收到这些数据项。但是，当BehaviorSubject完成时，订阅者不会再收到最后一项数据。
BehaviorSubject的优势在于它可以用于需要获取最近数据项的场景，比如缓存最新的数据、状态管理等。它还可以与其他操作符结合使用，实现更复杂的数据流处理逻辑。
在腾讯云的产品中，与RxJava相关的产品包括云函数SCF（Serverless Cloud Function）和云消息队列CMQ（Cloud Message Queue）。云函数SCF是一种无服务器计算服务，可以用于处理异步任务和事件驱动的场景，而云消息队列CMQ则提供了可靠的消息传递服务，可以用于实现消息的发布和订阅。
更多关于腾讯云产品的信息，可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
我有一个简单的RxJava，使用ReplaySubject，我可以得到结果，其中所有3个数字都被打印出来。System.out.println("Start $result in Subscription Result")当我更改为Behavior时，我希望打印第三个数字，即3，因为我一直认为Behavior是重播最后发出的项val observable : Observable<Int> = Observable.just(1, 2, 3)
val subject = BehaviorSubje
浏览 1提问于2017-07-22得票数 3
回答已采纳
1回答
我仍然是RxJava的新手，正在尝试用它来实现一些东西。
我的Android应用程序中有通知计数器，我希望每隔五分钟从API中获取计数，并希望将此计数共享给多个活动。因此，我希望将计数存储在管道中，以便每个监听该管道的活动都可以获得最后发出的值。但问题是，当我监听BehaviorSubject时，它会发出管道中的所有数据！我怎么才能只拿到最后一个呢？: BehaviorSubject<Any> = BehaviorSubject.createDefault(FetchEven
浏览 0提问于2018-09-20得票数 0
如何对可观察到的项进行分组，并且从每个GroupedObservable中只保留最后发出的项？这样每个组的行为就像BehaviorSubject一样。{user: 1, msg: "Hello"}因此，在内存中，每个user只有最后一项当订阅者订阅时，这两个项目就会立即发布(每个项目都是在其
浏览 5提问于2015-12-08得票数 8
回答已采纳
我在使用rxjs大理石测试BehaviorSubject时遇到了问题。最小复制量： const response$ = new BehaviorSubject(1);
expectObservable
浏览 4提问于2022-07-25得票数 0
然而，如果我使用Behaviorsubject，它工作得很好。谁能给我解释一下为什么会这样。this.msgStatistics.asObservable(); this.msgStatistics.next(message)
private msgStatistics = new BehaviorSubject<Object>(n
浏览 4提问于2021-08-05得票数 0
我使用的是BehaviorSubject，它会像预期的那样发送回订阅的最后一件商品。然而，有时，数据不会改变，新的listen事件的and将与最后发出的项一起被触发回来。然而，在新的listen上，重新创建了事件流，并且没有历史记录。除了最后一件。有什么合理的解决方案来处理这种情况吗？总而言之，我们如何继续使用BehaviorSubject，但过滤/区分最后一项？
浏览 9提问于2020-02-10得票数 1
distinctUntilChanged() .autoConnect();
后续订阅服务器正常工作，接收最后的值
浏览 5提问于2016-04-11得票数 0
回答已采纳
在阅读RxJava时，我注意到您可以控制流完成的时间，也就是说，当最后的排放被发送到下游时。现在还不清楚你是如何控制这一切的。我在RxJava上看到的大多数示例将允许您使用诸如"just“或"fromIterable”之类的方法和数组来创建一个可观察的示例。然后，数组中的每一项将被发送到流中，然后在处理最后一次发射后调用onComplete。当然，您可以应用诸如“采取”之类的操作符，这也会导致onComplete在发送完排放量后执行。
浏览 1提问于2019-03-11得票数 0
回答已采纳
我想用RxJava实现一个EventBus，我需要粘性事件。我知道我可以使用BehaviorSubject，但它只缓存最后发出的项，而我想缓存所有按类型(类名)区分的事件。有没有一种方法可以创建一种只按类型元素唯一保存的ReplaySubject？
浏览 0提问于2017-09-04得票数 0
我是RxJava的新手。2)如果其他人订阅了observable，那么subscriber将在没有API调用的情况下获得已经缓存的数据(来自第一个subscriber)。第3，4个订阅者也是如此...private final BehaviorSubject<Profile> profile = BehaviorS
浏览 9提问于2017-12-13得票数 3
我希望从它获得类似BehaviorSubject的语义，这样在订阅时，订阅服务器就会接收到传递过滤器的最后一项。然而，BehaviorSubject似乎并不是被设计成卡在链的中间，而只是作为一个源。有办法做到这一点吗？
浏览 5提问于2015-06-15得票数 3
回答已采纳
1回答
也许我忽略了一个简单的操作符组合(或者完全忽略了RxJava固有的取消行为)。但是，假设我有一个可观察到的热门selectedItem，它将平面映射到RxJava查询。@Test Database db = null; //assign db
/
浏览 6提问于2015-09-25得票数 6
回答已采纳
在RxJava2版本的RxAndroidBle中，函数readCharacteristic()和writeCharacteristic()返回Single<byte[]>。但是establishConnection()从来没有完成过。
浏览 0提问于2018-03-13得票数 0
2回答
如何从BehaviorSubject on 检索最新值
一些背景信息:我正在使用RxJava实现MVVM模式。我的ViewModel封装了BehaviorSubject的“可绑定属性”，我将它们绑定到UI元素作为可观察的元素，以确保接口不断更新(而且由于使用了BehaviorSubject，即使订阅是在设置值之后发生的当然，BehaviorSubject会以某种方式缓存它，因为它会为订阅者重新发布最新的价值。然而，BehaviorSubject.last()只返回一个Observable
浏览 2提问于2015-06-06得票数 7
回答已采纳
对于那些在RxJava2方面有经验的人，我有一个问题。-> { });创建一行可能是非常耗时的操作，所以我会在每次发射后更新问题是getRows()方法被多次调用，我只需要向用户显示最后一组发射。你有什么意见建议？
提前谢谢。
浏览 1提问于2018-09-05得票数 1
2回答
我只是在学习安卓系统中的RxJava，以及MVVM、数据库和RxJava (假设的)优秀的组合。不幸的是，我不能将RxJava Observable直接绑定到View：需要LiveData。@BindingAdapter("rxText")
public static void bindReactiveText(EditText view, BehaviorSubject<String>现在，我确实尝试订阅主题并为每个发射调用setText，但是接下来我必须释放Observ
浏览 6提问于2020-02-21得票数 2
2回答
等到第二个可以观察到的发射
、、、、
在Rxjs中，有管道takeUntil，但是没有管道等待直到，这使得当前可观察到的等待第二个观察到的发射。import { takeUntil, skipWhile, skipUntil, concatMap, map, take } from 'rxjs/operators';
import { BehaviorSubject} from 'rxjs';
浏览 2提问于2020-03-21得票数 2
回答已采纳
1回答
自从我将其更改为Singleton服务后，它就在第一次加载中工作，当我第一次访问该页面时，没有显示任何数据，也没有触发任何订阅事件。
浏览 2提问于2016-11-06得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
