rxjs5

3熱

1答えて

私はxに新しいイベントを送信する場合、これが出力されます、次のコード x = new Rx.Subject() z = new Rx.Subject() loop = 900000000; x .do(() => console.log('x start')) .do(() => { let i = loop; while(i--) continue }) .

-1熱

1答えて

Rxjs：lettable演算子でプロパティが見つかりません

Angular 5.0.0にアップグレードした後でimportステートメントにLettable Operatorsを使用しようとしていますが、このエラーが発生します。このコードブロックに障害が発生した場合 ERROR in src/app/components/hero-detail/hero-detail.component.ts(32,8): error TS2339: Property 's

1熱

2答えて

Angular 4 to 5 Upgrade - Observable.of

Angular 4/rxjsコードを新しいバージョン5の構文を使用するように更新しようとしていて、何らかの問題が発生しています。オリジナルimport文： import { Injectable } from '@angular/core'; import { Http, Response, Headers, RequestOptions } from '@angular/http'; im

0熱

3答えて

オペレータを最後にAngular/Rxjsアプリにインポートする

Angular 5アプリでlastオペレータをインポートするのに苦労しています。私たちはRxjs 5.5.2を使用しています。私が間違っているのは何 ... import { Observable } from 'rxjs/Observable'; import 'rxjs/add/operator/last'; /* ... */ getData() { return Obse

0熱

1答えて

Rx.Observable.Ofエラーがキャッチされていない

localStorageからトークンを戻してエラーをキャッチしたい。 Observable.of(JSON.parse(localStorage.getItem('currentUser')).token) .catch((er) => Observable.of(console.log(er)) しかし、それをキャッチしません。面白いのは、私が試してキャッチメソッドを使用すると、私はエラー

0熱

1答えて

reduceを使用すると、呼び出しが完了しない件名

RxJSが新しくなりました。私はRxJsを使用しています。5.5.2 簡単にするために、私は被験者に対して次回に呼び出すたびに値を減らしたいと思います。私はsub.complete()何も起こりません呼び出すことはありません場合は今 const sub = new Subject<number>(); const obsesvable = sub.pipe( reduce((a, b)

2熱

1答えて

RxJSパイプの仕組み（lettable演算子）

これは実際には自分には注意しますが、他の人にとっては有益な場合があります。だから、ここ2つのコードの断片とギッターの私の質問です：これら二つ？： @Effect() loadRegistrationsFailed$: Observable<Action> = this.actions$ .ofType(registrations.LOAD_FAIL) .pip

1熱

1答えて

reactとwebpackで動作しない単一のrxjs演算子をインポートする

私はreactアプリケーションとwebpackを束縛するためにredux-observableを使用しています。私は import 'rxjs/add/operator/mapTo'; ようrxjsから特定のオペレータを含む場合それは動作し、エラー TypeError: action$.ofType(...).mapTo is not a function. をスローしかし、私は完全なr

2熱

2答えて

RxJS 5.xでfromを使用してObservableを作成する最も良い方法は？

「lettable」演算子があるので、Observableを別のものから作成するにはどうすればよいですか？私がやろう： import {Observable} from 'rxjs/Observable' const source = Observable.from(someOtherStream) fromは今個別にインポートする必要が何か他のものであるので、私は、理にかなってエラーOb