observable

    0热度

    1回答

    我已经使用RxJS Observer功能在角度4中编写了认证系统。查询Oracle数据库是基于查询流在服务中转换为observer/observable,然后在登录组件中使用登录形式,我订阅服务中的obervable以获得身份验证结果。服务的方法返回的可观察对象在用户进行身份验证时发布“true”或“false”。通过单击登录表单组件中的登录按钮,将显示加载动画并隐藏登录表单。当用户通过身份验证时

    2热度

    1回答

    concat调用发生了什么?我知道如果我通过merge代替concat,代码正常工作,输出为foobarquxquux。我已经阅读了关于热和冷的可观察性,并且我知道如果在订阅之前生成的值可能会发生热的可观察性,但是我的可观察性下面有cold,所以我认为情况并非如此。 const Rx = require('rxjs'); const observable1 = Rx.Observable.cr

    0热度

    1回答

    我正在使用angular4。 我正在尝试使用observable进行实时更新。 这里是我的代码 首先我导入observable import { Observable } from 'rxjs/Rx'; import { AnonymousSubscription } from "rxjs/Subscription"; import { ApiServiceProvider }

    0热度

    1回答

    我对可观察数据的知识是有限的,所以可能很明显我在这里做错了。 在我的Angular 2组件上初始化时,会发生此调用。 ngOnInit(): void { this.route.paramMap .switchMap((params: ParamMap) => this.userService.getUser(+params.get('id'))) .subscr

    1热度

    1回答

    需要帮助,至将角色2应用程序中的数据传递给另一个函数。 在这个应用中我从服务器获取数据 问题:无法将数据发送到一个功能到另一个功能service.ts 预计:获取价值和阅读它在第二个功能。 请注意:由于它是一个服务器客户端集成我没有一个plunker或jsfiddle。 第一功能 getDLFolders() { return this.http.get(this.url + '/al

    0热度

    2回答

    如果我想在RxSwift中模拟例如Bool的标准属性,我可以使用let isValid = Variable<Bool>(false),然后使用.value获取最后一个内联值,并使用.asObservable()访问该流。 但是,我想模拟计算propery例如var isValid { return self.password.characters.count > 0 },并且还能够以可观察流的形

    0热度

    2回答

    我想使用默认值的主题发出值。 startWith("def")是此方法。 subject = new Rx.Subject().startWith("def value"); 不幸startWIth回报Observable,所以我不能使用onNext(),这是我使用的首位主题的唯一原因。这个问题的解决方法是什么? subject.onNext("next val"); //cannot cal

    1热度

    1回答

    我为此尝试了很多事情,似乎没有任何帮助。 我试图做到: 用户点击选择组件视图 事件触发按钮,选择组件上调用changePage() 此呼吁服务changePage()并传递在一个字符串中 changePage()在服务更新中observable 在主成分,subscription被创建并且基于在服务Observable的可变pageName值 的pageName更新为页面 服务 上的报头 impo

    1热度

    1回答

    我不想在next()方法上做任何事情,我想要处理error()和complete()。 这是我的作品以及当前的解决方案: this.myService.myServiceObservable(params) .subscribe( () => { /**/ }, error => { // Handling errors here

    0热度

    1回答

    我有一个web服务,提供有关当前在收音机上播放的(最后一首)歌曲的信息。 我的observable如何更新我自己的http请求中的数据? 我的供应商: load() : Observable<{}> { return this.http.get(this.URL).map(res => res.json()); } 我的组件: this.radio.load().subsc