腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
4
回答
如
何在
Rx
中
使用
异步
方式
订阅
?
c#
、
async-await
、
system.reactive
有没有办法
异步
观察数据?我尝试了async void,它工作,但我觉得给定的解决方案是不可行的。
浏览 41
提问于2016-05-24
得票数 16
回答已采纳
1
回答
异步
流如何与反应性扩展相比较?
c#
、
system.reactive
、
c#-8.0
、
iasyncenumerable
Rx
更强大吗?} c => Console.WriteLine(c.ToString()),
异步
流
浏览 4
提问于2019-10-20
得票数 15
回答已采纳
3
回答
从可观察对象创建BehaviorSubject
reactive-programming
、
rx-java
假设我有一个observableA,它从网络获取数据并发出数据,如果我每次
订阅
这个可观察对象,它都试图从网络请求大量数据。我想创建BehaviorSubject并将其连接到observableA,这样任何其他线程/对象都将
订阅
BehaviorSubject,以便获得最新发出的数据。 到目前为止,我还不能把它写成代码。我不能
订阅
observableA并让BehaviorSubject作为观察者,你知道我如何才能做到这一点吗?或者甚至更好?
浏览 3
提问于2014-06-06
得票数 10
1
回答
异步
Disposable.Create
c#
、
asynchronous
、
async-await
、
system.reactive
、
dispose
在释放
Rx
订阅
时运行Action。还是有其他处理
异步
处理的模式?
浏览 4
提问于2017-07-24
得票数 6
回答已采纳
2
回答
在数组上
使用
RxJs运算符
arrays
、
linq
、
rxjs
、
rxjs5
我知道当
订阅
Observable时,RxJ observables是随着时间的推移而产生的
异步
集合。 // I want to use on collection instead of
Rx
.Obser
浏览 1
提问于2016-10-10
得票数 1
2
回答
如何取消
订阅
或取消对可观察到的大型数组的筛选?
javascript
、
rxjs
、
reactive-programming
我的理解是,整个数组被推送到
订阅
者,不像可以取消
订阅
/取消的间隔观察者。// emit a value every second for approx 10 seconds .take(10)// emit a rangelet obs =
Rx
.Observable.from(
浏览 1
提问于2018-05-22
得票数 0
回答已采纳
1
回答
为什么“`rxjs/no-
异步
-
订阅
”存在?“
订阅
”
中
的“
异步
”有什么问题?
typescript
、
rxjs
、
eslint
禁止的模式是(禁止
使用
async关键字):为什么这是件坏事?我在某个地方看到了这是因为它不受支持,但是我已经测试了它,并且它可以工作,我可以在回调函数中
使用
await,并且它可以工作。
浏览 2
提问于2022-03-21
得票数 0
回答已采纳
1
回答
对可观测数据
使用
ObserveOn的必要性?
c#
、
c#-4.0
、
system.reactive
或者类似地,我需要在MethodThatMustBeOnUIThread
中
检查InvokeRequired吗?谢谢。编辑:嗯,我在调试器
中
尝试过,“MethodThatMustBeOnUIThread”确实是从后台线程调用的。为什么会这样呢?我现在的假设是,默认情况下,观察发生在运行
异步
方法的线程上。
浏览 3
提问于2012-01-31
得票数 3
回答已采纳
1
回答
在保持
订阅
的同时更改可观察流
javascript
、
rxjs
、
observable
、
reactivex
在RxJS
中
,我希望
订阅
保持在流上,即使在流更改时也是如此。下面我
使用
了一个间隔流来测试这种行为。//Works because foo$ is unchangedfoo$.subscribe(x => console.log(`foo$: ${x}`)); let bar$ =
Rx
.O
浏览 3
提问于2016-04-25
得票数 5
回答已采纳
2
回答
C#
Rx
如何正确处理所创建的可观察的源枚举
c#
、
ienumerable
、
system.reactive
、
dispose
、
idisposable
我想将一个IEnumerable,IDisposable (源代码)改编成一个可观察的,并且想知道最好的方法来做到这一点,并让source.Dispose方法被取消
订阅
。但是内置版本似乎没有在取消
订阅
时调用对源IEnumerable的Dispose。理想情况下,我希望
使用
.Publish().RefCount()模式在同一个源上拥有多个
订阅
者,并且只有当源Dispose()全部未
订阅
时才调用它们。 以下是我尝试的代码,尽管它不起作用。
浏览 4
提问于2016-12-20
得票数 3
回答已采纳
1
回答
如何覆盖
订阅
rxjs
我遇到了一种情况,我需要在一个函数中放置一个
订阅
,这个函数被多次调用。var subscription = new
Rx
.Subscription(); var numbers = observable.from换句话说,我会在任何时候只有一个
订阅
活动吗?
浏览 1
提问于2018-05-30
得票数 1
2
回答
当我想要一个
使用
rxjs可以观察到的防火墙
中
的一个对象时,我是否应该仍然
使用
订阅
?
firebase
、
firebase-realtime-database
、
rxjs
我有点搞不懂哪种方法属于什么方法,什么时候
使用
它们。 现在,我
使用
的基本上是所有的
订阅
,当我想从Firebase
中
获得一个快速的静态值时,它并不适用于我。你能解释一下我什么时候应该
使用
订阅
和其他方法,而不是为了一个严格的可观察性?
浏览 0
提问于2016-12-14
得票数 1
回答已采纳
2
回答
可供观察员
使用
rx-java
、
rx-java2
在RxJava
中
,与观察者
订阅
的
订阅
返回可以取消
订阅
的
订阅
。
rx
.Observable<Long> v1hot =
rx
.Observable.interval(1, TimeUnit.SECONDS);
rx
.Observer<Long&g
浏览 1
提问于2017-01-02
得票数 6
2
回答
在
Rx
中
是否有与Task.ContinueWith运算符等价的?
c#
、
system.reactive
在
Rx
中
是否有与Task.ContinueWith运算符等价的?我在Silverlight中
使用
Rx
,我
使用
FromAsyncPattern方法进行两个webservice调用,并且我想同步进行它们。var o2 = Observable.FromAsyncPattern<int, string>(client.BeginGetData, client.EndGetData); 是否有一个运算符(
如
Zip)只在o2返回完成后才会启动/
订阅
o1?我以
浏览 2
提问于2011-07-19
得票数 4
回答已采纳
1
回答
为什么意图服务一开始就调用onDestroy()?
android
、
android-service
、
retrofit2
、
intentservice
、
rx-android
是因为网络调用的所有方法都被调用并且它们存在于不同的线程
中
吗?那么服务就死了?
浏览 0
提问于2017-06-12
得票数 2
回答已采纳
1
回答
取(1)和取消
订阅
的区别
angular
、
rxjs
、
observable
假设我不
使用
异步
管道。我想
订阅
component.ts文件
中
的一些内容。如你所知,如果不是http请求,我应该取消
订阅
。方法1)在那里实现onstruction钩子和取消
订阅
。
方式
2)
订阅
时,
使用
采取(1)。采取(1)将处理取消
订阅
本身。 我的问题是-如果我们不需要
异步
管道,为什么会有人选择1的
方式
,以及我们应该
使用
哪一种
方式
来
浏览 0
提问于2019-02-11
得票数 3
2
回答
在特定时间调用可观察方法的最佳
方式
是什么?
c#-4.0
、
system.reactive
、
reactive-programming
我正在
使用
RX
创建一个
异步
Web请求。有没有一个好的调度器来在预定义的时间调用Web请求?我不知道该用哪一个: Task Scheduler还是
RX
Scheduler。
浏览 1
提问于2011-11-10
得票数 0
回答已采纳
1
回答
新奥尔良谷物编码
中
的反应扩展
c#
、
system.reactive
、
orleans
在项目中有一个重要的更新: 由于是支持新的C# 8
异步
流特性的第一个LINQ实现,Ix
异步
4.0与以前的版本有很大的不同。在其他平台上,我们提供了实现,因此您可以像预期的那样
使用
would并创建
异步
迭代器。这些类型将统一到平台提供的系统类型。 这里有许多重大的变化,一套完整的变更笔记正在进行
中
。这个库能在新奥尔良代码中用于处理谷物
中
的流吗?我知道
RX
使用
自己的调度器来运行观察者和
订阅
(例如ObserveOn()和Sub
浏览 0
提问于2019-03-10
得票数 3
回答已采纳
1
回答
为什么在第一次
订阅
热门对象后不触发
订阅
javascript
、
rxjs
在我的代码
中
,我
使用
share()创建了一个热的observable,如果我没有完成observable,或者
使用
setTimeout将其设为
异步
,则只执行第一个
订阅
,之后的任何附加
订阅
都不会执行。const c=
Rx
.Observable.create((obs)=>{// add this will work // setTimeout(()=>obs.next(1)console.log
浏览 2
提问于2018-06-07
得票数 0
2
回答
反应式扩展Observerable.FromAsync:如何等待直到
异步
操作完成
c#
、
system.reactive
在我的应用程序
中
,我从消息总线(rabbit,但实际上这并不重要)获取事件。该事件的处理花费了相当长的时间,并且事件是以突发的形式产生的。一次只能处理一个事件。为了实现这一点,我
使用
Rx
来序列化事件并
异步
执行处理,这样就不会阻塞生产者。Task.Delay(1000).ConfigureAwait(false);} 示例应用程序正在处理
订阅
但在此示例
中
,应用程序正在终
浏览 38
提问于2020-06-16
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Reactive Programming 学习笔记
UniRx-Unity响应式编程插件(1)
UniRx-Unity响应式编程插件(5):消息系统 对象池
响应式编程和Rxjs库介绍
RxWX在小程序和wepy中的使用方法
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券