behaviorsubject

2熱

1答えて

アプリケーション全体で聴くことができるangular2でイベントを放出する方法はありますか？ AngularJSのように、$rootScope.broadcastとemitを使用しています。これはangle2でも同じことができますか？私は@Output()とEventEmitter()について読んでそれを実装しましたが、それは親だけが子によって出されたイベントを聞くことを制限します。私は約Beh

0熱

1答えて

放射後に最後の値を削除するBehaviorSubject

誰かがBehaviorSubjectのカスタム実装を知っていて、加入者がそれを消費したら最後の値を破棄しますか？なぜこのような実装は悪い考えですか？私は問題を回避このようにハッキング

2熱

1答えて

Observable BehaviorSubjectサービス - シングルトンとプロバイダ

私はプログレスバーを表示する（または表示しない）ために、単純なコンポーネントprogressBarを持っています。そして、簡単に観察できるサービス。ここでがサービスである：ここでは派手な import { Injectable } from '@angular/core'; import { Http } from '@angular/http'; import { Observable

0熱

1答えて

Angular2でObservableを変更するとBehaviorSubjectが発生する

Select Marketをクリックすると、Observableにデータの配列が設定されます。最初の項目は、プロパティが選択されているため、黄色で強調表示されます。フォーカスが入力ボックスにあるときは、リスト内を矢印で下に移動できます。問題はBehaviorSubjectが起動し、毎回サーバーからのデータのリストを取得することです。 SearchTerms BehaviorSubjectを毎回起動

8熱

1答えて

BehaviorSubjectから作成された角度2のrxjs observablesがforkJoinと連携していません

Observable.forkJoinを使用しようとしていますが、subscribeハンドラがヒットすることはありません。 forkJoin演算子は私のアプリケーションの他の部分で私のために働いています。私が考えることのできる唯一の違いは、asObservable()関数を使ってBehaviorSubjectオブジェクトから観測値が作成されていることです。これは、サブスクライブは、この1つは私の

1熱

2答えて

BehaviorSubjectは元の値にリセットされ続けます

私には2つのコンポーネントがあります。コンポーネントの1つは、サブスクリプションを使用してメンバー（前述のBehaviorSubject）を追跡します。 BehaviorSubjectの値は、ユーザーがボタンをクリックすると更新され、プッシュされます。ただし、購読すると、これまでにプッシュされた値だけが元の値（つまり0）になります。 Navbarコンポーネントは、CountServiceでBe

0熱

1答えて

科目 - [？BehaviorSubject.onBeforeNext]ごとに次の値に変更を適用する

では、簡単なBehaviorSubject this.countryOfBirth$ = new BehaviorSubject<CountryEnum>(null); get countryOfBirth() { return this.countryOfBirth$.value; }; set countryOfBirth(val: CountryEnum) {

0熱

2答えて

BehaviorSubject/Angular2で初期化されたグローバル変数での作業

私はカタログコンポーネントとカートサービスを持っています。カタログ（JSONに格納されたオブジェクトの配列）の商品をカートに追加したいとします。私は商品を追加/削除するときにカートを動的に変更する必要があります。そのため、{BehaviorSubject}を使用しようとしています。カートサービス： import { Injectable } from '@angular/core'; i

1熱

1答えて

RxJava：BehaviorSubjectがソースからの後続の排出を受信しないObservable

BehaviorSubject（RxRelay.BehaviorRelay経由）を使用して、最新の排出を連続したObservableから保存しようとしています。「連続」とは、元のデータセットが変更されるたびにデータを放出するようにソースObservableが設計されていることを意味します。 BehaviorSubjectは、ソースObservableにサブスクライブされています。 Behavio

1熱

1答えて

Rx PublishSubject.onNext（）の呼び出しと受信の間隔が長い

バックグラウンドスレッドではPublishSubject.onNext();と呼び出し、メインスレッドではsubscribe(PublishSubject.filter(message -> message.getId() == id), this::onMessageInserted);を受け取ります。平均所要時間は約20ミリ秒です。この時間を少なくする方法はありますか？私たちは、私はそれが可