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