observable

    0热度

    3回答

    如何通过方法getUserInfo()更改服务中的Observable中的值? @Injectable() export class UserInfoService { public User: UserInfo = { firstName: "O", lastName: "K", email: "[email protected]",

    1热度

    1回答

    我正在使用WebSockets与后端WebApi进行通信。一切工作正常,除了我不能从我的服务返回我的自定义对象。 我正在使用Angular 4.3.4和rxjs 5.4.3。 //ngInit from my component ngOnInit() { this.modelsSubscription = this.mainService.getModels().subscribe(m

    0热度

    1回答

    我正在尝试为angular2中的身份验证服务上的登录方法编写单元测试。我面临的问题是Observable.subscribe是异步的,不会在我的测试中运行,因此localStorage.setItem永远不会运行。我试图让我的代码返回一个承诺,并使用茉莉花完成,但这似乎也不工作。我应该如何去测试这个功能? 从认证服务代码 login(username: string, password: stri

    0热度

    1回答

    我是新来observables,有它返回Observable<void>, 在这个方法我得叫childMethod返回Observable<responseObject>,之后我得到responseObject我应该发表一个http请求,并返回一个parentMethod Observable<void>,执行的呼叫和顺序很重要,像下面这有语法错误代码。我应该怎么想,我该怎么做? public c

    0热度

    1回答

    我正在使用RxSwift进行集合视图和表视图中的表单处理。我面临一个问题。 我有一个选择列表组件,每次配置时都会创建DisposeBag以删除所有以前的订户。 onDisposed方法被调用,但我仍然收到重复onNext事件。这在开始时正常工作,但当我重新加载集合视图或表视图时,我正面临着这个问题。请让我知道是否有什么我做错了或是库中的这个错误。 var selectedIndex = Varia

    0热度

    1回答

    的数组我有一个返回这个[ [Obj1, Obj2, ...], [Obj1, Obj2, ...] ]一个zip运营商,目前我这样做是为了得到什么,我想 map(x => [...x[0], ...x[1]]) 是有,这是否操作?

    0热度

    1回答

    我希望将observables合并为一个,然后在所有主体发出价值时订阅。到目前为止,我已经试过Observable.merge和Observable.zip public A:Subject<any> = new Subject(); public B:Subject<any> = new Subject(); public C:Subject<any> = new Subject(); p

    -1热度

    1回答

    关于addItem项目被push到productList数组中,但是在点击cart选项卡后,cartcomponent中的productList会被重新初始化(清空productList数组)。如何避免重新初始化数组? export class CartComponent implements OnInit { public productList: any[] = []; c

    0热度

    1回答

    我需要创建2个http请求(第二个依赖于第一个请求),以将用户credentiels插入到我的数据库中。 第一个服务获取用户密码(http://localhost:55978/FleetViewDBWebService.asmx/ChekCreds?name=name1&subname=subname1),并检查用户是否已经存在,返回'ID'(如果存在)或返回“OK”(如果用户不存在)。 然后我需

    0热度

    2回答

    我正在尝试使用kotlin学习RxJava2,我正在关注this良好的在线教程。首先,我加入这两条线的gradle.build文件: compile 'io.reactivex.rxjava2:rxandroid:2.0.1' compile 'io.reactivex.rxjava2:rxjava:2.1.3' 的我试图执行这段代码的可观察的模式: import io.reactivex.