腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
flatMap
未被
调用
swift
、
combine
我正在尝试使用两个单独的函数
调用
来验证用户的电子邮件和密码。这两个函数都返回验证发布器,我使用combineLatest将返回值收集到一个元组中(每次AnyPublisher
调用
都返回它正在验证的字符串)。然后,我使用
flatMap
发出一个网络请求,让用户使用combineLatest返回的值进行注册,但是从未
调用
过
flatMap
操作符。email, with: [.validEmail]) .combineLatest(validator.validate(text: password, with:
浏览 6
提问于2019-12-24
得票数 1
回答已采纳
1
回答
在RxJS可观察的
flatMap
中运行await
asynchronous
、
async-await
、
rxjs
、
observable
、
flatmap
我试图在传递给
flatMap
的异步箭头函数中返回一个可观测对象,但返回的可观测对象
未被
调用
。Session> { .pipe(
flatMap
浏览 17
提问于2018-12-31
得票数 2
回答已采纳
1
回答
在RX-java1.2中在可观察到的onNext上发出单个
rx-java
PublishSubject.create();single.subscribe(anySubscriber);subject.
flatMap
(nothing -> single.toObservable()).toSingle().subscribe(anySubscriber); 但在这种情况下,anySubscriber从
未被
调用
,因为subject没有完成。
浏览 2
提问于2017-05-03
得票数 1
1
回答
Java 8中的覆盖率报告
java
、
unit-testing
、
java-8
、
code-coverage
考虑取自的以下示例 .
flatMap
(Soundcard或者其他一些,这告诉我filter闭包根本没有被
调用
,因为列表是空的?是否可以报告forEach中的方法引用
未被
使用?
浏览 3
提问于2016-02-24
得票数 8
1
回答
Springboot webflux reactor从mongoDB删除项目
spring-boot
、
spring-webflux
) { Flux.fromIterable(ids) return cityService.findById(id) .
flatMap
浏览 19
提问于2021-10-23
得票数 0
回答已采纳
1
回答
异步弹簧安全WebFilter
spring-boot
、
spring-security
、
reactive-programming
、
spring-webflux
,但是它从
未被
调用
过。email = headers.get(EMAIL_HEADER).get(0); .
flatMap
浏览 3
提问于2017-07-22
得票数 0
回答已采纳
1
回答
停止rxJava可观察链的处理
android
、
rx-java
、
rx-java2
在应用程序中调试rxJava网络
调用
时,我遇到了这样一种情况:如果我们通过订阅observables链返回dispose或clear处理对象,那么只有第一个observable才会被
flatMap
释放,sbr.onNext(true); sbr.onComplete(); }).subscribeOn(Schedulers.io()).
flatMap
浏览 3
提问于2017-09-04
得票数 7
回答已采纳
1
回答
如何确保所有观察者从多个并行订阅中看到相同的结果
reactive-programming
、
rx-java
首先从互联网或缓存获取会话;第二次
调用
服务器api,使用会话Observable<MyResult> apiCall = getSession.
flatMap
(session -> {}我想要的行为:getSessions应该
调用
一次,其他观察到的人首先在等待getSessions
调用</e
浏览 4
提问于2015-06-10
得票数 0
回答已采纳
1
回答
RxJava2如何将单链链接到可完成的对象,以便在可完成的情况下订阅
android
、
rx-java2
根据调试,该方法中的单个似乎被
调用
,但从
未被
订阅(即
调用
downloadUser()方法,但它创建的单个方法中没有代码被
调用
)。password) repository.downloadUser() // This is a Single
浏览 0
提问于2018-06-01
得票数 4
回答已采纳
1
回答
为什么switchIfEmpty内部的mono没有被执行?
reactive-programming
、
spring-webflux
、
project-reactor
、
reactive
在下面的代码逻辑中,someFunction()被
调用
,但是functionThree中的mono从
未被
执行。即使“有效”被记录,但是从存储库返回的mono永远不会被执行。SomeFunction() { return functionOne(param).
flatMap
(param -> functionTwo(param)).then(Boolean.TRUE
浏览 2
提问于2022-07-28
得票数 0
2
回答
SpringWebflux。在无功流之间切换
java
、
spring-webflux
、
project-reactor
public Mono<Subject> create(Mono<Subject> subject) { .
flatMap
(s -> subjectRepository.findById(s.getParentId())) subject.doOnNext(child -> {child.setRoute(Utils.buildRoute(child, p
浏览 2
提问于2022-03-31
得票数 0
回答已采纳
1
回答
如何在发生错误时停止反应器
flatMap
java
、
spring-webflux
、
project-reactor
Report> collectReport(List<MarkId> marks) { .
flatMap
buffer(1000) .
flatMap
为了提高加载速度,我决定用
flatMap
替换这个
flatMap</
浏览 2
提问于2020-11-11
得票数 0
回答已采纳
1
回答
获取doOnSubscribe、doOnSuccess和doOnError中的反应堆用户上下文
spring-boot
、
project-reactor
例如,使用
flatMap
: String name = ctx.getOrDefault(虽然我可以使用doOnEach检查signal.isOnNext()或signal.isOnComplete(),但我发现signal.isOnSubscribe()从
未被
调用
过。
浏览 0
提问于2018-08-21
得票数 4
1
回答
Flink AssignTimeStampsAndWaterMark
apache-flink
、
flink-streaming
我的代码就像 .assignTimeStampAndWaterMarks( WaterMarkStrategy
浏览 2
提问于2022-05-25
得票数 0
1
回答
反应卡夫卡-如何正确地执行手动提交?
spring-boot
、
apache-kafka
、
project-reactor
、
reactive-kafka
one message, I am creating Flux of items which are transformed and then send to another topic 有人能指出我做错了什么吗?我是一个非常新的项目反应堆(和反应编程)。
浏览 11
提问于2022-10-26
得票数 0
1
回答
OnSubscribe位置导致OnComplete事件过早触发
android
、
rx-java
、
rx-android
我有一段代码,它的工作原理是: .map().
flatMap
().doOnNextendpoints.getRecentConversations(page) .map().
flatMap
onNext()从
未被
调用
过,在我的logcat中也没有出现错误。 我可以把事情保持原样,
浏览 0
提问于2017-01-13
得票数 0
1
回答
InputStream的迭代者:如何关闭InputStreams?
scala
、
functional-programming
、
iterator
Iterator[InputStream[CustomType]] = retrieveStreams() val results: Iterator[MyResultType] = streams
flatMap
我唯一的问题是,单个InputStreams从
未被
关闭过。有办法这样做吗?
浏览 4
提问于2015-09-25
得票数 2
回答已采纳
1
回答
确保RxWorker永不失败
android
、
kotlin
、
rx-java
、
android-workmanager
我正在实现我的第一个WorkManager,用于与服务器进行每日同步,这可能会返回一个HTTP错误,从而使createWork()流失败并
调用
onError(),从而在流的订阅中“抛出”一个Result.failure我想确保Result.failure()从
未被
调用
,并且总是
调用
Result.retry()。System.currentTimeMillis()
浏览 1
提问于2020-01-03
得票数 0
回答已采纳
1
回答
如何确保在第一次
调用
完成之前不会再次运行rx java observable
android
、
rx-java
、
android-syncadapter
一旦
调用
了同步,我们需要阻止来自操作系统的对该同步适配器的任何其他
调用
,直到我们完成处理来自第一个同步的响应为止。我以为在Single上
调用
.blockingGet()就可以了,但事实并非如此,在允许再次
调用
/订阅Single之前,我如何确保Single中处理的所有代码都完成了呢?.
flatMap
(this::updateHistories) .
flatMap
(
浏览 15
提问于2017-11-17
得票数 1
2
回答
flatMap
在Scala中的实现
scala
在Scala中的函数式编程中,我们为map、getOrElse和Option类型的
flatMap
提供了以下定义: case Some(x) => x} map(f) getOrElse
浏览 5
提问于2014-12-31
得票数 3
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
5G工业应用未被开发
5G工业应用未被开发
拘于小节的调用权限——函数调用权限漏洞
AIER研究表明比特币价格未被操控
地球上未被证实不明神秘生物有哪些?
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券