草庐IT

observable

全部标签

javascript - Observable 的设置值未在 Knockout 中更新

(每天都有大量问题链接回为什么我不能设置我的可观察值的值,而不是有这么多不同的答案说同样的事情我想创建一个问题来引用大家)KnockoutObservable/ObservableArray的设置值不更新设置我可观察的observableArray的值没有更新!向Observable数组添加一个项目为什么我不能将项目添加到我的Knockout可观察数组中? 最佳答案 KnockoutObservable/ObservableArray的设置值不更新您需要使用setter函数来更新您的observable/observableArra

javascript - RxJS:如何使用 Observables 执行 "if"?

假设我有两个observable,如果另一个符合特定条件,我想监听一个observable的变化。我用zip尝试过,但似乎只有当bothobservables发生变化时,我才会收到通知,但如果条件另一个是正确的。我尝试过的:varfirstState=newRx.BehaviorSubject(undefined);varsecondState=newRx.BehaviorSubject(undefined);Rx.Observable.zip(firstState,secondState,function(first,second){return{first:first,second

javascript - 重试后如何获取catchWhen?

我想重试几次get请求,并在出现错误时延迟一秒,但如果所有尝试都失败,则执行错误处理程序。以下代码重试请求,但从未执行catch。我该如何解决?import{Response,Http}from'@angular/http';import{Observable}from'rxjs/Rx';import'rxjs/add/operator/catch';import'rxjs/add/operator/map';this.http.get("/api/getData").map(data=>{console.log('get')returndata.json()}).retryWhen(

javascript - 订阅/取消订阅 Rxjs Subject 时如何接收通知

我正在尝试使用Rxjs来管理大型状态树中的垃圾回收。我如何创建一个运算符来接受每次可观察对象的订阅者数量发生变化时触发的回调函数? 最佳答案 多种方式,都涉及隐藏您的主题并为消费者提供包装的可观察对象:想知道什么时候有人订阅了您的主题吗?constsubject=newSubject();constobservable=Observable.defer(()=>{someoneJustSubscribed();returnsubject;});returnobservable;想知道有人何时取消订阅?constsubject=new

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

论文阅读:Observation-Centric SORT: Rethinking SORT for Robust Multi-Object Tracking——OC-SORT

前言文章的一作是曹金坤,作者同时还是《TransTrack:MultipleObjectTrackingwithTransformer》的二作。文章:https://arxiv.org/pdf/2203.14360.pdf代码:https://github.com/noahcao/OC_SORT本文为论文阅读记录,本人才疏学浅,应该有错误的认识,希望读者能在评论区帮助我改正错误。文章提出了一种用于多目标跟踪的算法Obeservation-CentricSORT(OC-SORT),以解决多目标跟踪中模型对目标重叠、非线性运动的敏感和需要高帧率视频的问题。OC-SORT保持了简单、在线、实时的特点