observable

    1热度

    3回答

    在我的项目中,我有一个服务,应用程序启动时应该加载本地数据库。为此,使用功能GetData()。我尝试通过拨打ngOnInit()生命周期挂钩来使用它。它将结果记录在控制台中,但属性datum看起来没有改变。 但是,如果我将GetData()方法添加到按钮,属性会更改并且数据按照预期显示在控制台中。 ,我看遍了所有的消息表明,正确的方式来加载数据库,如果我需要它的时候是使用ngOnInit()钩,

    1热度

    1回答

    投票我最近询问有关订阅如果switchMap遇到错误丢失了一个问题: Angular 4 losing subscription with router paramMap using switchMap 的解决方案是返回一个空的观察为一次可观察命中一个错误订阅将被销毁。 我现在需要弄清楚如何使用相同的代码查询,但停止轮询一旦API返回的数据 - 我相信这回空可观察到导致如预期我投票代码到不行。 当

    1热度

    2回答

    我想要显示包含在与每条消息(特别是每条消息的作者名称)相关的所有信息的聊天中的消息列表。 所以我有以下的函数,返回可观察到的消息数组的: getLastMessagesOfEvent(eventId: string, limitTo?: number): Observable<any> { console.log('MessageService#getLastMessagesOfEven

    1热度

    2回答

    我在转换我的observable时遇到问题。详情如下: 我有这样 [ { 'firstName': 'John', 'lastName': 'Cash', 'age': 20 } ]; 数据然后我从API得到这样的数据: public getData(): Observable<Data[]> { return thi

    2热度

    2回答

    挑战! 我的问题是如下: 我有得到观察到的,需要充实人的数据,并更新与可观察到的 哪个人对象看起来像一个观察者的函数: export interface Person { personId: string; children: Child[]; } export interface Child { childId: string; } 和EnrichPer

    0热度

    2回答

    @effect() public loadAccommodations$: Observable = this.actions$ .ofType(PAA.PROPERTY_LOAD_REQUEST) // .debounce(300) // introducing this mitigates the flood but does not resolve the

    1热度

    1回答

    我对观察者非常陌生,担心内存泄漏。如果我创建了以下内容: private client = new BehaviorSubject(""); clientStream$ = this.client.asObservable(); 和susbscirbe到他们的观点,像这样: this.clientService.clientStream$.subscribe( client => {

    0热度

    1回答

    你好吗。我是Rxjs的新手。我不确定如何合并来自不同事件的观察值。我综合Rxjs与Vue.js export default { name: 'useraside', data: function() { return { searchKey: '', isPublic: true } }, components:

    0热度

    1回答

    我正在建设我的第一个网站的角度。我试图调用一个webAPI并在我的组件中显示结果。这是我的服务代码: getVeselVisit(): Observable<VesselVisit> { let result = this.http.get(this.baseUrl + '/values/GetVesselVisit/') .map(res => <VesselVisit>

    1热度

    1回答

    目前我正在使用下面的代码来检查任何服务器更新,检查服务器在每5秒,如果从服务器更新显示通知和弹出。但我不想用户定时器,而是想要像新的短信或电话来的东西来。同样,服务器上的任何更新都会在不需要人们观察的情况下花费太多时间。 setInterval(function(){ this.dbProcess.dataProcess('','getServerUpdate.php').subscri