Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
在反应中从父组件调用子组件的方法是反模式吗?为什么?
我正在尝试实施一个具体的Wizard用户可以使用以下模式使用的组件
javascript
ReactJS
reactiveprogramming
Mono switchIfEmpty() 总是被调用
我有两个方法 主要方法 PostMapping login public Mono
Java
springboot
reactiveprogramming
SpringWebFlux
projectreactor
了解 rxjs 中的背压 - 仅缓存 5 个等待上传的图像
我正在开发一个节点项目 需要提交数千张图像进行处理 在将这些图像上传到处理服务器之前 需要调整它们的大小 因此我有一些类似的内容 imageList map image gt loadAndResizeImage merge 3 map i
javascript
nodejs
rxjs
reactiveprogramming
rxjs5
如何为流数据创建 Flux/Publisher
我正在使用轮询方法定期获取数据 新数据可能随时到达 我想向我的客户公开一个反应式接口 因此 我想创建一个发布者 Flux 它会在新数据可用时发布新数据并通知订阅者 我怎么做 我看到的所有 Flux 示例都是针对数据已知 可用的情况 实际上
Java
reactiveprogramming
projectreactor
什么是(函数式)反应式编程?
Locked 这个问题及其答案是locked help locked posts因为这个问题是题外话 但却具有历史意义 目前不接受新的答案或互动 我读过维基百科的文章反应式编程 http en wikipedia org wiki Reac
functionalprogramming
terminology
reactiveprogramming
FRP
如何在 RxJS 中通过 ID 去抖
我的问题是下一个 我想取消我的应用程序的点赞功能 我使用操作在我的应用程序中进行更改 例如 dispatch likePost 1 gt dispatch type LIKE POST id 1 给出下一个例子 我在时间 0 发送一个操作
javascript
redux
rxjs
reactiveprogramming
如何在自定义 rxcpp 运算符上调用 on_error
我创建了一个简单的 rx 运算符 它将字符串流转换为 json 流 并且工作正常 但是 我希望能够引发自定义异常 并且我不知道如何调用on error认购方式 操作员称为convertStringToJson可以在此处找到工作示例 http
c
reactiveprogramming
rxcpp
Rxjava 中“背压”一词是什么意思?
我是 RxJava 的初学者 我很好奇 背压 这是否意味着生产者在背后给消费者施压 或者这是否意味着消费者正在向生产者施加压力 反方向施压 RxJava 背压 当你有一个 observable 发射物品的速度太快 以至于消费者无法跟上流量
RXJava
reactiveprogramming
backpressure
RXJS while 循环进行分页
我尝试查询所有人员的数据swap api http swapi co URL swapi co api people 返回一个带有 people 数组的对象 以及我从中获取下一个数据的 URL swapi co api people pag
javascript
angularJS
typescript
rxjs
reactiveprogramming
Spring Webflux 抛出“block()/blockFirst()/blockLast() 正在阻塞,线程reactor-http-nio-2 不支持”
我在 Spring Webflux 中执行阻塞操作时遇到一个小问题 我检索文章文档列表 并从文章文档列表中 我想更新另一个对象 当我执行下面的代码时 有时它会起作用 有时会抛出 block blockFirst blockLast 正在阻塞
springboot
reactiveprogramming
SpringWebFlux
如何将 BlockHound 添加到 Spring Boot 应用程序以检测阻塞调用?
如何将 BlockHound 添 加到 Spring Boot 应用程序以检测阻塞调用 我没有找到任何 Spring Boot 应用程序的示例 https github com reactor BlockHound blob master
Java
springboot
reactiveprogramming
使用 TcpClient 和反应式扩展从 Stream 读取连续字节流
考虑以下代码 internal class Program private static void Main string args var client new TcpClient client ConnectAsync localhos
c
Stream
systemreactive
tcpclient
reactiveprogramming
从打字稿和 Angular 中的 Observable
获取字符串值
我想从 Observable 获取字符串值并将该值从函数返回给调用者函数 例如 我有一组键 想一一获取所有键的值 字符串 并将其显示在具有菜单栏的 html 组件中 这是 ts 文件 key list component ts public
angular
typescript
rxjs
reactiveprogramming
Mono 与 CompletableFuture
CompletableFuture在单独的线程上执行任务 使用线程池 并提供回调函数 假设我有一个 API 调用CompletableFuture 这是 API 调用阻塞吗 线程会被阻塞直到它没有从 API 得到响应吗 我知道主线程 tom
Java
reactiveprogramming
projectreactor
CompletableFuture
RxSwift:管理应用程序中的对象更新
我非常关心如何管理对象属性的更改 假设我有一个 汽车 类 其中包含一些属性 例如 名称 日期 价格 等 在我的视图 A 中 我正在显示从 API 检索的所有汽车 在视图 B 和 C 中 我可以显示和编辑有关视图 A 中所选汽车的特定信息 假
swift
reactiveprogramming
RxSwift
rxjs:定期执行一些操作,中间有特定的延迟
客户端应用程序向服务器发送请求 这可能需要很长时间才能完成 一旦请求完成或失败 客户端应该等待一段时间 即10秒 然后再次发送请求 目前的工作解决方案是这样的 appRequest new Subject ngOnInit void thi
angular
rxjs
reactiveprogramming
带有 vararg observables 的 RxJava zip
当我们确切地知道有多少个具有确切类型的可观察量并且我们想要压缩时 我们会这样做 Observable
Java
reactiveprogramming
RXJava
我应该使用 akka.http.scaladsl.util.FastFuture 而不是 scala.concurrent.Future 吗?
我应该使用 akka http scaladsl util FastFuture 而不是 scala concurrent Future 吗 评论说 Provides alternative implementations of the b
scala
concurrency
akka
reactiveprogramming
akkahttp
Java反应式框架的比较[关闭]
Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我看到许多框架 库声称它们可以帮助用 Java 构建响应式应用程序 例如 Akka Vert x RxJava Reactor QBit 等 他
Java
akka
reactiveprogramming
RXJava
projectreactor
如何在发布之前将取消令牌插入 ReactiveX 流(IObservable)?
如何将取消令牌插入现有的IObservable调用前的管道Publish在其上 即 在它成为IConnectableObservable 在订阅它之前 这必须是冷可观察管道的一部分 否则 我可以传递一个CancellationToken令牌
c
NET
reactiveprogramming
ReactiveX
rxnet
1
2
3
4
5
6
...9
»