腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
DirectProcessor
的
替代品
是什么
java
、
spring
、
reactive-programming
、
project-reactor
、
spring-cloud-stream
我有一个卡夫卡出版商,它发布
的
数据使用项目反应堆
的
DirectProcessor
类。但根据official document
的
说法,
DirectProcessor
将被弃用,并将在3.5版中删除。当前实现 @Bean return
DirectProcessor
.create(); @Bean} 这里是供应商,它使用上面配置
的
D
浏览 21
提问于2021-10-31
得票数 0
1
回答
Flux.repeat()不重复
java
、
reactive-programming
、
project-reactor
我试图重复一次这样
的
磁通订阅: stringDirectProcessor.onNext("three");我
的<
浏览 0
提问于2019-06-28
得票数 0
回答已采纳
1
回答
春季反应中
的
MonoProcessor是用来做什么
的
?
spring
、
project-reactor
、
spring-reactive
在查看Spring框架中
的
WiretapConnector源代码时,我偶然发现了一个MonoProcessor类型
的
对象。我试着在谷歌上搜索它
的
用途解释,但没有结果。Javadoc对一个反应型/反应堆外行来说不多: 最后一句暗示计算结果被缓存,这似乎是MonoProcessor在这个中
的
使用。有人能澄清Mo
浏览 1
提问于2020-05-19
得票数 0
回答已采纳
1
回答
使用AssertionErrors ()在反应堆StepVerifier中重新抛出Schedulers.single
java
、
project-reactor
为了测试这段代码,如下面的ServiceTest所示,在为异步操作设置时,我们让Mono将结果传递给测试可以访问
的
带有doOnNext
的
DirectProcessor
,然后使用执行测试调用和断言。JavaDoc of 读取 我们发现,只有在使用立即调度程序()时才是正确
的
,而使用单个调度程序()时则不正确。当使用单个调度程序时,AssertionErrors不会被重新抛出,即测试总是通过
的
。<Response> process
浏览 0
提问于2017-11-24
得票数 0
回答已采纳
1
回答
使用具有超时
的
订阅服务器动态发布单个项目
java
、
spring-webflux
、
project-reactor
目前,我们有两个独立
的
API端点。(data); }}当前方法
的
问题是,数据可能在get请求超时后发出,并且订阅被取消,从而丢失数据。
浏览 0
提问于2020-07-29
得票数 0
1
回答
服务器发送带反应堆
的
事件弹簧webFlux
spring
、
reactive-programming
、
server-sent-events
、
project-reactor
这是否是通过浏览器客户端发送公共主题信息
的
正确方式?@RestController
DirectProcessor
<String> topicData =
DirectProcessor
.create
DirectProcessor
,没有可能
的
背压,我想知道流量是如何消耗时,发送通过sse。订阅服务器是否可以请求少于在流量中推送
的
数字元素?因此,如果您推送N个元素,
DirectProcessor
浏览 5
提问于2017-12-15
得票数 0
回答已采纳
1
回答
如何处理Project Reactor中
的
处理器订阅中引发
的
异常
java
、
spring
、
project-reactor
考虑以下测试:void test() {我知道客户端可以将代码包装在try-catch内部订阅中,但是有没有其他方法呢?例如,有时可能会发生NullPointer,或者客户端可能会忘记检查异常。对于API来说,强制客户端尝试捕获所有异常也是不方便
的
。 处理这种情况
的
最佳策略
是什么
?
浏览 0
提问于2019-05-03
得票数 0
1
回答
如何为流数据创建Flux/Publisher
java
、
reactive-programming
、
project-reactor
我想向我
的
客户公开一个反应式接口。所以,我想创建一个发布器(Flux?)这将在新数据可用时发布新数据,并通知订阅者。我该怎么做?我看到
的
Flux
的
所有示例都是针对数据已知/可用
的
情况。实际上,我想要
的
是基于队列
的
Flux,当我
的
轮询线程发现新数据时,它可以继续填充队列。
浏览 27
提问于2019-06-25
得票数 5
2
回答
在应用程序运行期间动态地将事件/值推送到Flux
java
、
asynchronous
、
reactive-programming
、
project-reactor
必须异步地将状态发送到需要独立和独立于主流处理
的
流。我偶然发现了这个链接: public class StatusEmitterImpl implements StatusEmitter { this.processor =
DirectProcessor
浏览 0
提问于2019-01-26
得票数 3
回答已采纳
1
回答
如何通过aysnc回调创建多个Flux
java
、
project-reactor
从Reactor
的
参考指南中,我了解到可以使用Flux.create()将aysnc回调转换为Flux。然而,有时回调有多种方法来接收多种类型
的
数据,假设我有一段如下
的
代码: asrService.recognize(new Callback() { public void
浏览 13
提问于2019-01-28
得票数 2
回答已采纳
1
回答
将Flux/Publisher/Subscriber连接到持续生成器
java
、
reactive-programming
、
project-reactor
我有一个不断生成和存储新数据值
的
类(使用线程池)。我希望为客户端代码(“订阅者”)提供一种方法来利用(连接到)新数据值
的
序列。但是,如果我
的
类没有客户端,或者所有客户端都完成了序列
的
读取,我希望它继续生成和存储新值,而不是停止。当客户端连接到该序列时,它会接收新生成
的
值,但不会接收过去生成
的
值。我想我需要使用Flux来表示新值
的
序列,但是使用哪个Flux类(或工厂方法)呢?
浏览 24
提问于2019-01-23
得票数 1
2
回答
项目反应器:为每个订阅
的
发布者缓存最后一项
project-reactor
我有一个处理器,可以订阅任意时间到达
的
出版商。对于处理器
的
每个新订阅者,我希望从每个发布者发出最后一个条目。class PublishersState {Subscriber2: Item 1 publisher1 Subscriber2: Item 2 publisher2 有没有一种简
浏览 18
提问于2019-03-17
得票数 0
回答已采纳
1
回答
DirectProcessor
和UnicastProcessor可以在不该订阅
的
情况下订阅上游出版商。为什么?
spring
、
reactive-programming
、
project-reactor
根据项目反应堆关于处理器
的
文件: UnicastProcessor<String> hotSource = UnicastProcessor.create(); Flux<String正如文档中所述,这是不可能
的
。医生说我漏掉了什么是错
的
吗?
浏览 0
提问于2018-03-28
得票数 1
回答已采纳
1
回答
将对象写入flux
java
、
spring
、
spring-boot
、
kotlin
、
project-reactor
这就是我到目前为止所得到
的
,但是write不是一个函数: @Controller data class Lobby(val
浏览 43
提问于2020-06-14
得票数 0
回答已采纳
1
回答
Spring Reactor多订阅
rx-java2
、
spring-webflux
、
project-reactor
我试图将我
的
单声道分裂为其他分离
的
单声道,这些单声道将在不同线程上处理相同
的
数据输入数据。我想使用.cache()方法,但我想知道一些新
的
更好
的
方法来只调用一次API并处理成倍
的
数据?如果Reactor不能做到这一点,我可以将Reactor换成RxJava。
浏览 28
提问于2019-12-08
得票数 1
5
回答
javascript
的
替代品
是什么
?
javascript
javescript
的
替代品
是什么
?我认为JQuery是jave script
的
一个很好
的
替代品
,尽管它是使用Java script开发
的
。我想知道有没有其他类似的..请给我任何关于这个
的
链接或信息
浏览 6
提问于2011-11-24
得票数 0
1
回答
FluxProcessor:在订阅时检索最后发出
的
值,类似于rx
的
主题
java
、
spring
、
spring-webflux
、
project-reactor
、
reactive
目前,FluxProcessor订阅仅检索在订阅之后发出
的
那些值。例如,我想在订阅时检索Flux中
的
最后一个值,就像RX
的
Subject一样。我有这样
的
设置: FluxProcessor<Integer, Integer> processor =
DirectProcessor
.
浏览 38
提问于2019-10-11
得票数 0
回答已采纳
1
回答
NetLogo
替代品
种
netlogo
我想知道是否有一个替代
的
品种功能在网络标志? 我在字典里找了一个
替代品
,但我只找到了globals,我不认为它能完全涵盖品种
的
功能。如果有
替代品
的话,那
是什么
?
浏览 2
提问于2015-04-13
得票数 0
回答已采纳
2
回答
std::unique_ptr与boost::ptr_container
的
stl容器
c++
、
stl
、
c++11
、
unique-ptr
、
boost-ptr-container
有了c++11,我问自己在c++11中是否有boost::ptr_containers
的
替代品
,我知道我可以使用例如std::vector<std::unique_ptr<T> >,但我不确定这是否是完全
的
替代品
建议
的
处理这些情况
的
方式
是什么
?
浏览 6
提问于2012-02-28
得票数 19
回答已采纳
2
回答
J2ME
的
最佳替代方案
是什么
?
java-me
朋友们,我想知道J2ME最好
的
替代品
是什么
。当我参考Net时,我发现了以下内容,但我仍然感到困惑,哪一个是J2ME
的
最佳
替代品
。 2.
浏览 0
提问于2010-10-21
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
PowerPoint的10大替代品
区块链的“便宜”替代品
那些优秀付费应用的免费替代品
6 个开源的奇妙清单替代品
扫盲 VeraCrypt——跨平台的TrueCrypt 替代品
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券