rxjs

    0熱度

    1回答

    我有一個角度爲5的應用程序,rxjs WebsocketSubject發送jsonrpc消息。 這是我sendRequest將功能 sendRequest(request: Request): Promise<Response> { console.log(request); this.socket.next(JSON.stringify(request));

    1熱度

    1回答

    最近,我的團隊將Angular 4項目遷移到了Angular 5.同樣在此遷移中,我們開始使用Angular cli。一切正常,項目正在運行,我們終於設法減少了包的大小(aot,樹震動,構建優化器等)。 唯一的問題是,在最終捆綁包中,rxjs似乎包含兩次(bundle analyzer screenshot)。 當然,我們改變了所有可見進口 import {Observable} from 'rx

    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

    0熱度

    1回答

    在我的應用程序中有2個模塊,即AppModule和UserModule。 但我在共享AppComponent和LoginComponent(它是UserModule的一部分)之間的數據共享時遇到問題。 這裏是app.component.html <ul class="nav navbar-nav lg-nav visible-lg visible-md"> <li><a routerL

    4熱度

    1回答

    警告:RxJS newb在這裏。 這裏是我的挑戰: 當onUnlink$觀察到發射... 立即開始從onAdd$觀察到的捕獲值,最多1秒(我會打電話給此分區onAddBuffer$) 。 查詢數據庫(創建doc$觀察到的)來獲取我們將使用來匹配的onAdd$值之一 如果從onAddBuffer$觀察到的一個值的doc$值相匹配的模式,不排放 如果沒有值從onAddBuffer$觀察到的doc$值匹

    0熱度

    2回答

    我有一個角度服務,我想暴露一個observable,它充當邏輯「或」的類。假設我有多個源序列可以給出on和off的值。我需要輸出true任何時候任何東西都是on,並且當所有值爲off時返回false。 例子: const replaceInput = input => input === 'on' ? 'off' : 'on'; const getSource = (name) => Obser

    0熱度

    1回答

    我有一個熱門的RxJS Observable,我想根據應用程序的上下文采用不同的方式進行響應。該主題發出基於由指令攔截一些全球性行動的新事件,但後來我想 若一個子組件訂閱的主題,那麼孩子應該處理該事件 否則,使用全局處理程序 我可以從主題獲取訂閱者的數量,然後告訴全局處理程序忽略是否有多個訂閱者,但它不是API的一部分,所以它看起來可能不是正確的方式來處理它。那麼做這件事的正確方法是什麼? 此外,

    1熱度

    1回答

    爲了教育目的,我需要模擬Angular 2中服務器的長響應。我有代碼 getTasks() : Observable<Task[]> { return this.http.get('data/tasks.json').map(response => { return response.json(); }); } // using getTasks().sub