RxJava2合并和多播事件流

文章/答案/技术大牛

发布

1回答

rx-java2

我有一个事件源，它发出一个后跟Deltas的Snapshot，假设它看起来有点像 Flowable.just("A", "1", "2", "3") 其中"A“是快照，"1”、"2“、"3”是更新。我想要检索第一个订阅者 "A", "1", "2", "3" 和第二个订阅者(假设它出现在"2“和”3“之间)来接收 "A".apply("1&

浏览 7提问于2019-03-11得票数 1

回答已采纳

1回答

我们的网络支持许多多播流使用pimd。如果我们在multicast_source_ip文件的phyint部分使用"altnet pimd.conf masklen 24“语句，那么许多(但不是所有)多播流才会流。这些多播流是动态地添加或删除的，因为某些网络设备是根据一整天的特定事件来启动/下降的。在整个一天中，pimd.conf文件可以多次添加或删除这些altnet语句。经过短时间的重新发现，<e

浏览 0提问于2020-03-10得票数 0

回答已采纳

1回答

Dart (带有rxdart)和其他反应性库(如RxJava和RxJS )之间的主要区别是什么？

stream、dart、flutter、reactive-programming

在以下方面有哪些主要区别：订阅管理

浏览 0提问于2018-06-29得票数 5

1回答

rxjava为什么不是所有的订阅者都选择事件？

rx-java、reactive-programming、observer-pattern、observers、reactivex

我一直在构建一个系统，在这个系统中，我在套接字上查看消息并发送给订阅者。然后，订阅者将处理消息(如果是针对他们的话)，该消息可以从发送给他们的消息中得知。我相信可以使用rxjava实现这一点。我有两个订阅者，对于消息编号123，其中只有一个被通知为not both。我是一个rxjava/反应性编程新手。我有客户连接到 while (true) {

浏览 5提问于2018-02-16得票数 0

2回答

当接收到大量UDP通信量(Windows)时CPU负载高

c++、windows、multithreading、sockets、udp

我正在研究一个应用程序的问题，它使用大量传入数据进行进一步处理(具体而言，是多播传输流)。套接字代码使用WSA重叠的API。(NIC我正在使用: Intel PRO PT1000)我已经设置了一个小的测试应用程序，只有一个目标:从任意数量的多播</e

浏览 2提问于2014-01-08得票数 3

回答已采纳

3回答

如何正确转换RxJava中的多播观测值

java、android、rx-java、reactive-programming、rx-java2

假设我有一个事件发射数据源，我想将其转换为反应性流。数据源被资源绑定(例如，定期发送更新状态的套接字)，因此我希望共享该资源的单个订阅。最简单的解决方法似乎是在进行多播操作之前，将myDataObservable的单播变体保存到某个位置，然后在anotherDataObservable中执行多播操作。2.只需使用重复的多播运营商。第二个解决办法似乎是在replay和refCount操作符中再次应用anotherDataObservable。但是这造成

浏览 0提问于2018-05-18得票数 7

回答已采纳

1回答

使用Java swing制作交互式组件

java、swing、user-interface、shapes

我正在尝试映射一些服务器主机之间的数据流。这个想法是，数据在网络中的多播会话之间流动，我有一个数据来自和到达的表。我想要生成使用箭头来显示什么东西在哪里的图表。我已经使用图形库绘制了一些形状(用于主机的矩形和用于多播会话的椭圆)，并将形状的位置/比例数据存储在对象中，以便我可以计算箭头应该锁定的位置。我也在他们之间做了箭。使用paintComponent函数似乎不可行，因为我不能将事件添加到它绘制的形状中。我认为可以绘制箭头，然后将它们放入JLabel组件中，并在该组件上定义

浏览 48提问于2018-09-22得票数 -2

1回答

多次订阅rxjs观察者而不执行多个请求

ajax、asynchronous、angular、rxjs、observable

因此，我试图为我的角2应用程序实现一个定制的XHRBackend。这是我的课：import "rxjs/add/operator/catch";import {SlimLoadingBarService} from "ng2-slim-loading-bar"; exp

浏览 4提问于2016-10-14得票数 4

回答已采纳

1回答

反应堆/ WebFlux实现了一个反应式http新闻报

java、spring、project-reactor

我想返回一个application/stream+json类型的回复，其中包括有人发布的新闻事件。我不想使用Websockets，不是因为我不喜欢它们，我只是想知道如何使用流。String message;} 和端点分别发布新闻，获取新闻流。

浏览 1提问于2018-04-05得票数 3

回答已采纳

2回答

快速组合:那些多播功能是什么，我如何使用它们？

swift、ios13、combine、macos-catalina

Publishers.Multicast<Self, S> 但是，当我试图确认向多个订阅者发送时需要多播的假设时the credentials valid: true因此，似乎不需要多播来处理多个订阅者那么，这些多<

浏览 0提问于2019-07-06得票数 4

3回答

网络如何在途中复制数据包？

routing、internet

首都的服务器是否需要向所有的人发送相同的数据流，或者是否每个城市都有一个数据流，然后根据需要复制和分割？我知道在这个特殊的情况下，可能有一个被选择的ISP承载着流，他们可能在数据中心之间处理这样的系统，但是我是从一个更一般的意义上来问的。

浏览 0提问于2021-08-11得票数 4

1回答

应力测试视频流

video、streaming、load-testing

有没有办法对视频流进行压力测试？基本上模拟大量的人同时播放一个视频？这是一个亚马逊的‘云’服务，将为我的网站启用。

浏览 0提问于2011-04-28得票数 9

1回答

RxJS过滤/分组去跳

javascript、rxjs、reactive-programming、redux-observable

上面的代码应该像合并三个独立的$low.pipe(debounceTime(delay))、$medium.pipe(debounceTime(delay))和$high.pipe(debounceTime(delay))流一样工作

浏览 1提问于2021-01-08得票数 0

回答已采纳

3回答

使用JTable显示流数据时性能缓慢

java、performance、swing、jtable、event-dispatch-thread

我引用的代码是专有的，需要组播服务器，所以我不能发布SSCCE代码片段。我明白这可能会排除任何有用的见解，从而引发可行的回应……我认为我的代码结构是恰当的。这都是在事件分派线程之外完成的。这些行通常填充

浏览 4提问于2013-02-21得票数 3

1回答

用最少的投入将消防软管消息推到S3桶中

amazon-web-services、amazon-s3、aws-lambda、amazon-kinesis-firehose

我们有一个AWS动态流，它每秒摄入大约15条二进制消息。作为最后的手段，数据恢复策略，我们想转储所有收到的S3桶中的1-2周TTL。我们可以使用Lambda函数将每个转储到S3中的一个新文件中。我们处理多对一，所以我不确定什么结果/状态代码传递回消防软管。( AWS生态系统对我来说是非常新的，所以我想我可能错过了显而易见的解决方案。)

浏览 0提问于2018-11-28得票数 0

回答已采纳

1回答

RxJava只订阅特定的密钥

java、rx-java、rx-java3

我收到了无限的事件流，比方说Observable<Event> where Event(userId, payload)。我必须提供功能，允许订阅用户的事件。Observable<Event>是一个热点源，但这并不重要，因为如果没有感兴趣的用户，我可以删除事件。我试图使用RxJava API以纯流的方式来实现它，但这对我来说似乎很困难。userId) { }

浏览 4提问于2022-05-04得票数 0

回答已采纳

2回答

捕获事件的异常

c#、exception、dependencies

问题是，我无法从我的Socket类中捕获IOManager事件处理程序的异常。我不想在我的Logger类中注入TCPDataLink依赖项，因为我不想在所有DataLink类中重复日志代码。

浏览 5提问于2012-12-03得票数 1

回答已采纳

3回答

是否有移动应用程序替代硬件辅助听力系统？

android、ios、audio、streaming

例如，流延迟并不是真正的问题。与助听器兼容并不是一个问题。允许一个移动设备通过本地网络记录和广播音频流。支持至少安卓和iOS设备的最低数量的设置。安装说明将在事件开始之前给出，但让每个人都连接起来不应该是一种磨难。在某种多播模式下运行，这样WiFi就不会为每个侦听器填充单独的流</

浏览 0提问于2014-12-09得票数 4

3回答

委托中的协方差，有例子吗？

c#、.net、delegates、covariance、contravariance

我正在阅读，逆方差示例(键盘和鼠标事件)非常有用，而协方差示例(哺乳动物和狗)则不是这样。键盘和鼠标事件很棒，因为您可以为多个情况使用1个处理程序；但是，我想不出将一个返回派生类型更多的处理程序分配给返回基类型的处理程序的好处，更不用说让一个关心返回类型的委托看起来不那么常见了吗？

浏览 0提问于2015-08-07得票数 7

1回答

XStreams中忽略的第二个合并分支

reactive-programming、cyclejs、xstream-js

我的溪流和这张图一样在第一个会话var更新中，我得到了这个调试结果：如果我更新会话项(因此产生一个新的存储事件调试2

浏览 2提问于2019-06-09得票数 1

回答已采纳

点击加载更多