observable

    1热度

    2回答

    我开发了一个Ionic 3应用程序,它可以根据需要缓存文章内容列表。我正在使用Storage,它使用承诺进行操作。 我的代码如下: 物品service.ts getArticleFullData(articleId: number) { let appSettings = this.appSettingsService.getSettings(); let params = t

    0热度

    1回答

    我有一个Observable Obs1已使用从对象数组开始的方法from创建。 我们假设数组有10个对象,这意味着Obs1会发射10次然后终止。 对于由发出的每个对象Obs1我想执行一个返回Observable的函数。因此,相同数量的数组的元素由函数返回的观测量,我们姑且称之为Obs2-1Obs2-2 ... Obs2-10。这些观测值只发出1个值,然后完成。 我想以某种OBS1链接到一系列的观测

    0热度

    1回答

    我实施数据存储服务来分享多个兄弟组件之间的数据。每个组件都需要得到有关数据存储区更改的通知。数据存储不会自行填充,数据需要从控制器设置。 data.store.ts @Injectable() export class DocumentIssueStore { private _documentIssue: BehaviorSubject<DocumentIssueModel>;

    1热度

    3回答

    您好我对Angular和Observables来说很新颖 我想通过循环的方式获取对象的ID。 但没有收到我的订单响应。 例 get ID(1) get ID(2) get ID(3) Receive Object ID(2) Receive Object ID(3) Receive Object ID(1) 是否有可能让我回来的对象,以便? 下面是我多次调用我的服务功能: confe

    -1热度

    2回答

    为什么Observer界面有Observable?作为参数? 你是否推荐使用Javas现有类(实现Observer;扩展Observable)? public class Test implements Observer { void update(Observable o, Object arg); }

    1热度

    1回答

    我目前正在努力弄清楚Angular 4应用程序中Rxjs的行为。 我的代码是: this.server.get("incidents") //http get resource .flatMap((res) => res.value) //the incident array is in a property called value of the json returned .map((in

    1热度

    1回答

    我正在使用JWT刷新令牌策略作为身份验证,并且在我的Angular客户端中有一个拦截器将令牌作为标头发送。 我在发送之前检查过期时间,并在需要时使用我的refreshToken刷新令牌。 问题是发送2个(或更多)请求时,都尝试刷新令牌。我需要一个函数,它发送刷新令牌的req,并且一次调用多次,只向服务器发送1个http req以进行刷新,并将新的更新的令牌返回给所有调用它的人。 这是我的拦截器:

    4热度

    2回答

    我正在用Angular 4和websocket创建聊天应用程序。对于这一点,我已经按照这个Angular websocket tutorial 这里是WebsocketService源代码: import { Injectable } from '@angular/core'; import * as Rx from 'rxjs/Rx'; @Injectable() export clas

    4热度

    1回答

    警告:RxJS newb在这里。 这里是我的挑战: 当onUnlink$观察到发射... 立即开始从onAdd$观察到的捕获值,最多1秒(我会打电话给此分区onAddBuffer$) 。 查询数据库(创建doc$观察到的)来获取我们将使用来匹配的onAdd$值之一 如果从onAddBuffer$观察到的一个值的doc$值相匹配的模式,不排放 如果没有值从onAddBuffer$观察到的doc$值匹

    1热度

    1回答

    为了教育目的,我需要模拟Angular 2中服务器的长响应。我有代码 getTasks() : Observable<Task[]> { return this.http.get('data/tasks.json').map(response => { return response.json(); }); } // using getTasks().sub