Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
RX.Net:使用重试但记录任何异常
我是 RX 的新手 一直在研究错误处理和 Retry 的使用 我有以下内容 是的 我知道这不是 真正的 单元测试 但它给了我摆弄的地方 并且想知道如何保留重试但能够记录任何异常 Test public void Test var sched
c
systemreactive
rxnet
如何从 Rx Subscribe 回调异步函数?
我想回调 Rx 订阅中的异步函数 例如 像那样 public class Consumer private readonly Service service new Service public ReplaySubject
c
Asynchronous
reactiveprogramming
systemreactive
rxnet
使用 Rx 运行周期性任务并具有单个并发执行限制的好方法是什么?
我想运行周期性任务 但有一个限制 在任何给定时间最多只能运行一个方法的一次执行 我正在尝试 Rx 但我不确定如何施加最多一次并发限制 var timer Observable Interval TimeSpan FromMillisecon
c
systemreactive
rxnet
如何实现一个“更好”的Finally Rx操作符?
最近我意识到 RxFinally https learn microsoft com en us previous versions dotnet reactive extensions hh212133 v vs 103 操作符的行为方式
c
errorhandling
systemreactive
rxnet
如何在发布之前将取消令牌插入 ReactiveX 流(IObservable)?
如何将取消令牌插入现有的IObservable调用前的管道Publish在其上 即 在它成为IConnectableObservable 在订阅它之前 这必须是冷可观察管道的一部分 否则 我可以传递一个CancellationToken令牌
c
NET
reactiveprogramming
ReactiveX
rxnet
在Rx中,处理线程安全是消费者(IObserver)的责任吗?
在ReactiveX范式中 这是消费者的责任吗 IObserver 来处理线程安全 例如 如果OnCompleted来电时OnNext仍在另一个线程上执行 它看起来像来自 Rx NET 来源 但是the docs https learn m
NET
Multithreading
reactiveprogramming
ReactiveX
rxnet
如果结果来得太晚,则限制但丢弃结果
我正在编写一个用户界面 用户可以在其中输入搜索词 并且列表会不断更新以提供建议 我的第一反应是 Rx 原始 Throttle 是一个完美的匹配 但它让我成功了一半 这些建议需要一段时间才能获取 因此我在 UI 线程上异步获取它们 问题是 如
c
NET
systemreactive
ReactiveUI
rxnet
按时间或运行总和进行缓冲以进行反应式扩展
我对反应式扩展相当陌生 想要根据时间缓冲流 或者根据不超过阈值的运行总和 每个项目的大小由 lambda 指定 以先发生者为准 就像现有的Buffer按计数或时间 目前我已经编写了自己的实现Buffer方法按预期工作 使用ISchedule
c
systemreactive
rxnet
奇怪的Rx+CancellationToken问题:有时注册的回调未完成
我观察到一个奇怪的现象 有时会在我编写的 Rx 查询中发生 其中涉及CancellationToken 两个回调注册到同一个CancellationToken 一个在查询之外 一个是查询的一部分 的意图CancellationToken是发
c
systemreactive
cancellationtoken
rxnet
如何制作一个只能订阅一次的轻量级“Replay”算子?
在不同的场合我都希望有一个 RxReplay操作符缓冲传入的通知 在第一次订阅时同步重放其缓冲区 然后停止缓冲 这款轻量级Replay运营商应该只能为一名订户提供服务 可以找到此类运算符的一个用例here 在第一次订阅后继续缓冲只是浪费资源
c
systemreactive
rxnet
如何合并两个可观察量并提前完成
内置的行为Merge运算符完成时both来源已完成 我正在寻找这个运算符的一个变体 它产生一个可观察的结果 当any两个源可观察量的完成 例如 如果第一个可观察的成功完成并且later第二个可观察的结果有一个异常 我希望忽略这个异常 我想出
c
systemreactive
rxnet
从定期异步请求创建 observable
我想要一种将异步方法转换为可观察方法的通用方法 就我而言 我正在处理使用的方法HttpClient从 API 获取数据 假设我们有方法Task
c
Asynchronous
systemreactive
rxnet