rxjs

    0熱度

    1回答

    我在我的角度應用程序中有這個問題,因爲我正在緩存數據。使用onCreate()函數添加內容後。我在successfull subscribe函數中調用getAll()函數以獲取新數據。但是,我仍然沒有得到新的數據。我相信這是因爲我服務中的緩存數據。我如何知道是否有新數據或者當有新數據時如何修復我的現有數據和刷新數據? 服務 getAll() { if(!this.materials) {

    0熱度

    7回答

    目前,我正在開發Angular 4應用程序。在我的組件Html中,我有一個文本框。無論何時用戶首先鍵入任何我想要進行API調用以獲取某些數據。 問題是如果用戶鍵入'A',那麼它工作正常,並調用API。但是當用戶輸入「ABC」時,它會進行3次API調用。應該爲每個字母進行API調用,而不是隻進行一次調用。 請提出任何解決方案。 組件的HTML: <input id="inputbox" (keyup

    0熱度

    1回答

    如何才能延遲http請求,只有當它在1秒內完成。 第一種場景: - http請求在300ms內完成,然後等待1秒結束。 第二種情況: - http請求在1秒內完成並且300ms,那麼我們不會延遲。 如何用observables來實現這個?

    0熱度

    1回答

    edit See Ikhtiyor's answer as it may fix the TypeScript related issue. My problem came from the fact I forgot to .subscribe and wrote the handler function in .first() directly. 所以,面對這個錯誤(!?!): Propert

    0熱度

    1回答

    我有一個關於觀察到的問題。 例如,我們的API,併發送reguest有: this.http.get('https://swapi.co/api/people/').subscribe(peoplesData => { let peoples = peoplesData.json(); let nextPage = peoples.next; // https://swapi.

    1熱度

    1回答

    比方說,我有可觀察的可觀察名單: const a = [Observable.of(false), Observable.of(false)]; const aSbj: Observable<Array<Observable<boolean>>> = new BehaviorSubject(a); 我想所有的觀測量,結合內部成可觀察布爾[]的。這是我的想法(使用打字稿): const lis

    1熱度

    1回答

    我正在用mysql開發一個快速應用程序。我的節點版本是6.11.2。 我的路由器文件是 const router = require("express").Router(); const project = require("../../modules/project/"); // individual project routes router.get("/", project.getA

    3熱度

    4回答

    TLDR; 我想使用debounceTime來執行函數只有300毫秒已經過去,沒有被調用。與此同時,我也希望能夠每1分鐘觸發一次該功能。如果過程需要很長時間。否則,該功能只會在過程結束時觸發。 基本上,我們的系統有一個很長的過程,會向客戶端發出大量的SignalR更新。當我在客戶端接收到服務器命令時,我會向服務器發送2個額外的HTTP請求以獲取一些信息。所以只要發送給我的服務器更新,它就會重新啓動

    0熱度

    1回答

    我加載數據的方法,然後做設定,在每個數據同步的一些工作: // Invoked by user interaction loadData() { this.service1.getData().subscribe( data => { this.doSynchronousWork(data); this.data1 = data; }

    1熱度

    1回答

    它發現當我們攔截HTTP響應並使用subscribe獲取Observable響應中的值時,會觸發2次請求。下面是代碼 Intercerpting HTTP請求和響應通過延長它(http.service.ts) import { Injectable } from '@angular/core'; import { Http, XHRBackend, RequestOptions, Request