jjzjj

observable

全部标签

javascript - 在 Angular 中渲染基于时间的 Observables 而无需压倒性的变化检测

我们的Angular应用程序中有许多组件需要每秒定期显示每个组件唯一的新值(倒计时、时间戳、耗时等)。最自然的方法是创建使用RxJStimer和interval工厂函数的可观察对象。但是,这些会在整个应用程序的每个时间间隔触发Angular变化检测,调用时间间隔函数的次数。如果我们在页面上有几十个组件,这会触发整个应用程序每秒或每个时间段数十次的变化检测,从而产生很大的性能开销。到目前为止,我尝试了两种方法来解决这个问题。对任何一个的好的回答都会非常有帮助——最好是两者兼而有之。我想避免手动触发变更检测,而是依赖于Observables发出的新值,并让异步管道/OnPush变更检测策略

javascript - 如何在 observableArray 中订阅 observable

我正在使用KnockoutJS并尝试订阅位于observableArray中的observable。所以我的viewModel看起来像这样......functionviewModel(){//privatepropertiesvarself=this;//publicpropertiesself.movies=ko.mapping.fromJS([]);//subscriptionsself.movies.UserMovies.Rating.subscribe(function(newValue){console.log(newValue);});}moviesobservableA

javascript - Knockout,如何订阅observableArray的每一次变化

你能帮我订阅吗oneverychangeofmyobservablecollectionandoneveryitemchange.未找到关于http://knockoutjs.com/documentation/observableArrays.html的信息$(document).ready(function(){varItem=function(isSelected,isEnabled,errorState,name,group,processed,errors,state){varself=this;self._isSelected=ko.observable(isSelecte

javascript - Angular 2 将 APP_BASE_HREF 设置为来自 Promise/Observable 的值

我尝试使用来自异步rest调用的值在“CoreModule”中设置APP_BASE_HREF。我看不出这是怎么做到的,因为provide方法需要返回一个字符串。例如:@NgModule({imports:[...HttpModule],...providers:[......BackendRequestClass,{provide:APP_BASE_HREF,useFactory:()=>()=>return'/some/path',deps:[],multi:true}],});但是当我需要网络服务的值时,我无法返回字符串。知道如何做到这一点吗?谢谢 最佳

javascript - 我如何解析另一个 Observable 中的一个 Observable? - RXJS

我有一个Observable,我在其中使用了另一个observable,但是第二个Observable我无法解析。这是代码:returnObservable.fromPromise(axios(config)).map(res=>{return{accessToken:res.data.access_token,refreshToken:res.data.refresh_token}}).map(res=>{return{me:getMe(res.accessToken),accessToken:res.accessToken,refreshToken:res.refreshToken

javascript - Cold observable 和 Replay subject 之间的区别?

我可以从文档中看到:ColdObservables从一开始就向每个Observer发出整个值序列。和ReplaySubject向任何观察者发送源Observable发出的所有项目,无论观察者何时订阅。那么这两个概念有什么区别呢?谢谢 最佳答案 一旦ReplaySubject订阅了源observable,源就开始发射,并且ReplaySubject成为一个热的observable。从订阅者的Angular来看,订阅ReplaySubject可能并不明显,因为它获取了所有先前发出的值。但是ReplaySubject只订阅源一次,因此主题

javascript - RxJS Observable 返回数组,每次数组迭代运行另一个函数

我有一个函数getNews(),它基本上返回angular的http.get请求。请求的结果是Id的数组。我想遍历我得到的这个数组并运行另一个http.get请求(函数getItem(id)),然后它将返回从服务器接收的单个Id的对象。我试过这样使用它:getLatest(){returnthis.http.get('all_news_url').map(res=>res.json())//IeventriedcreatingObservablefromarrayandgetonly5elements//.map(res=>Observable.from(res.json()))//.

javascript - 如何重复 ajax 请求,直到满足 RxJS Observable 的条件?

我正在尝试重复请求,直到响应包含使用RxJS的数据,此时我想调用成功(或失败)处理程序,但我在使用RxJS时遇到了麻烦。这是我目前的做法://...redux-observableactionobservable.mergeMap(()=>fetchData().repeatWhen(response=>response.takeWhile(({data})=>!data.length).of(response))).map(successFunction).catch(failureFunction);免责声明:我对RxJS很陌生.... 最佳答案

javascript - Event.observe(window, "load", function(){..} v/s window.onload = function(){..}

即使两者做同样的事情,我只想知道使用一个比另一个有什么特别的优势吗?Event.observe(window,"load",function(){//dosomething});window.onload=function(){//dosomething} 最佳答案 区别在于window.onload是在DOMLevel0事件模型中定义的,将清除所有早期注册的事件。这是来自旧API的“native”调用。来自原型(prototype)javascript框架的Event.observe将确定可用的最佳事件附加器。外观模式。在现代浏览

javascript - rxjs 在 map Rx.Observable.range(1, 5).map 中使用 async/await

我想使用async/await从rxjs获取列表。我该怎么办?functiongetData(num){returnnewPromise((resolve,reject)=>{resolve(num+1)})}asyncfunctioncreate(){varlist=awaitRx.Observable.range(1,5).map(async(num)=>{constdata=awaitgetData(num)returndata}).toArray().toPromise()returnlist}Rx.Observable.fromPromise(create()).subscr