jjzjj

Observable

全部标签

javascript - knockout .js : manually trigger computed

我在页面上有一个网格和一个选择控件。选择任何选择值都会触发网格更新。该更新是使用计算完成的。我是否可以手动触发网格进行更新,例如,在将新值添加到网格的情况下?functionvm(){varself=this;self.items=ko.observableArray([]);self.chosen_category=ko.observable("");self.pager={page_namber:ko.observable(1),page_size:ko.observable(10)};self.sort={field:ko.observable('name'),dist:ko.o

javascript - RxJS - 捕获并继续

我正在努力按照我预期的方式处理Rx的错误。当我有一个Observable(例如,来自点击流)并且发生异常时,我想捕获它但继续。我尝试过的所有解决方案都会捕获错误然后结束Observable。有没有办法捕获并继续下去?例如,下面的Observable将发出“1”,然后是“Error”,但永远不会发出“3”。varrange=Rx.Observable.range(1,3).map(function(i){if(i===2){throw"Error";}else{returni;}}).catch(function(e){returnRx.Observable.return(e)});ra

javascript - Angular 2 rxjs 嵌套 Observables

我希望创建一个返回Observable的函数但在返回之前必须完成另一个异步任务(一个Observable),以便将值传递给返回的Observable.@Injectable()exportclassMyComponent{GetAuthToken=function():Observable{returnthis._storageService.GetAsString('authToken');}GetData=function(authToken):Observable{letheaders=newHeaders();headers.append('authToken',authTok

javascript - rxjs 观察数组推送

我想使用observables来监控对象何时被推送到数组中。我想从一个空数组开始,当发生推送时,我希望observable检测并处理它,然后等到下一次推送。这与可观察者等待事件的“fromEvent”非常相似。下面的代码立即调用completed()因为数组是空的,我如何让它等待推送?vartestArray=[];test(){varo={timestamp:newDate()}testArray.push(o)}varo=Observable.from(testArray).concatMap(x=>{returnx;});o.subscribe(x=>{console.log("

javascript - 从 redux-observable 史诗中访问状态

我正在使用redux构建一个小的fusball-manager。基本上它是一个页面,显示两个团队的分数和一些按钮来增加它们。我有像{type:"GOAL_UP",team:"red"}这样的操作,reducer将为此更改状态中的相应值(分数)。现在我想添加一个史诗,每当它遇到GOAL_UP时检查两支球队中的一支是否赢得了比赛。如果团队得分达到8,我希望它发送一个GAME_WON操作。我的问题是我必须访问状态才能知道每支球队的得分。我找不到从史诗中访问状态的方法。访问状态是否超出了redux-observable的范围?如果是这样,您将如何解决这个问题?我正在考虑将新分数作为GOAL_U

javascript - 在 Observable KnockOutJS 中退订

我目前正在使用KnockOutJS,我进行了一些研究,了解何时通知observable它将触发一个像这样的函数functionFunctionToSubscribe(){}varTestObservable=ko.observableArray([]);TestObservable.subscribe(FunctionToSubscribe);我正在订阅此事件中的FunctionToSubscribe我目前在想有没有办法取消订阅?就像我们在C#中做的那样?当取消订阅事件时,有人对此有想法吗??? 最佳答案 subscribe函数返回

javascript - 订阅 observable 返回 undefined

因此,我正在尝试订阅一个从本地JSON文件返回数据的简单服务。我已经设法让服务正常工作,我可以在函数中将其注销,但是当我在angular2组件中订阅服务时,它始终是未定义的。我不确定为什么?任何帮助将不胜感激。API服务exportclassApiService{publicdata:any;constructor(private_http:Http){}getData():any{returnthis._http.get('api.json').map((response:Response)=>{console.log('inresponse',response.json());//

javascript - 从多个 Observable 传递值

在我的Angular服务中,我有以下方法://createsanItemandreturnstheIDofthecreatedItemcreateItem(item:Item):Observable{returnthis.http.post('some_api_url',item);}//returnsallItemsgetAllItems():Observable{returnthis.http.get('some_api_url');}在我的模板中,我在列表中显示项目。我希望能够创建一个新项目,然后重新加载列表(以包括新创建的项目),所以我实现了以下内容:this.itemServ

javascript - dojo.store.Observable、JSON REST 和 queryEngine

有谁知道如何在dojo中使用JsonReststore和Observableweapper,比如dojo.store.Observable中的那个?服务器端,我需要什么来实现商店并使其作为可观察的商店工作?客户端呢?文档说http://dojotoolkit.org/reference-guide/1.7/dojo/store/Observable.htmlIfyouareusingaserversidestoreliketheJsonReststore,youwillneedtoprovideaqueryEngineinorderfortheupdateobjectstobeprop

javascript - Angular 和 Observable : how to avoid multiple requests to API within a given time

我在Angular4应用程序中有类似的东西(为了示例,我删除了代码)@Injectable()exportclassSomeService{constructor(privatehttp:Http){}get(id:number){returnthis.http.get('http://somedomain/somemodel/${id}.json');}}一些组件使用它来进行API调用。constructor(privatesomeService:SomeService){}...someMethod(){//codehere...this.someService.get(2).su