rxjs

    0

    1答えて

    私は20種類のイベントのストリームを持っています。 私は、過去10秒以内に似たタイプのイベントが発生した場合、各イベントにブール値を設定したいと思います。 これはライブで発生するはずです。イベントを10秒間遅延させたくありません。 イベントストリームは連続しており、 が、これはRxJsで行うことができ終わりませんか? UPDATE:はここに私のイベントストリームのJsBinデモでhttp://js

    4

    2答えて

    ベースクラスをcatchにすると、サブクラスをsubscribeに、Angular2のオブザーバブルにすることができます。 export class SomeBaseClass { constructor(private _http: Http, private _location: Location) {} protected _fetchData(url): Observ

    3

    2答えて

    いくつかのrxjs操作があるかどうか疑問に思っていました。私の並列非同期タスクが完了したかどうかを知るためにforkJoinを呼び出すことができるので、* ngIf = "loaded | async" angular2テンプレートで 私は1つの解決策を思いついたが、それは私にとっては厄介なようだ。 私はこれを行うクリーナーrxJSの方法があると確信しています。 plunkrあなたがそれを必要とす

    0

    1答えて

    私は私のプロジェクトでは、次のデータ型を持っている: プロジェクト ユーザー プロジェクトは、多くのユーザーを持っています。そこで、オブザーバブルを使用してビューを更新するプロジェクトサービスを作成しました。新しいプロジェクトが作成されたり、プロジェクトが削除されたりすると、これまでのところすべて正常に動作します。 ここでは、特定のプロジェクトに割り当てられているユーザーの一覧を表示します。新しい

    1

    2答えて

    私はこの演算子を完全に理解していません。 https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/groupjoin.md は、どのようにその部分を理解する: は、重複期間に基づいて2つのシーケンスの要素、およびグループの結果を相関します。 leftDurationSelector(機能):重なり

    17

    4答えて

    私は角度2のアプリケーションを持っています。サービスは、次のような結果を返すAPIからの要求データである: { "data":[ {"id":1,"timestamp":"2016-04-17T19:52:53.4510935+01:00","sourceDatabaseServer":"127.0.0.1","sourceDatabaseName":"Database1",

    0

    1答えて

    私は安らかなWebApiバックエンドからデータを返すAngular 2サービスに取り組んでいます。 サービスを正常に処理できないようにしようとしていますが、エラー応答に予期しない情報があります。 は、ここで私は、ネットワークトラフィックを見てみると、予想通り、私は404エラーを参照してくださいコード update(fund, transactionId:string, showToastOnErr

    0

    1答えて

    いくつかのRxJを習得しながらこの問題が発生しました。演算子チェーンをオブジェクトで開始し、フラットマップを使用してAJAXリクエストを行うにはプロパティのooeを使用しますが、Ajaxの結果とともに渡される他のオブジェクトのプロパティが必要です。私は以下の解決策を提示しましたが、よりエレガントで効率的な解決方法が必要であると確信しています。どのようにコードを改善するためのアイデア?一般的なパター

    0

    2答えて

    私はまだRxJSの周りに頭を抱えています。このパターンがあります。私は実行し続けており、もっとエレガントな方法で書きたいと思っています。 Model-View-Intentパターンコンポーネントのモデル部分を実装すると、入力としてアクションを取る関数があり、出力として単一のstate$が返されます。 function model(actions) { const firstPropert

    3

    1答えて

    それぞれの値がプロミスを指定した順序と同じ順序で返す配列をどうやって処理するのだろうと思いました。たとえば、のは、私はこのために複数のAjaxコールを呼び出したいとしましょう:How can I use RxJs to hold off any requests for an AJAX call until the previous one resolves、flatMapFirstを使用すること