observable

0熱

2答えて

私はこの大理石図を実装しようとしていますが、hipotesisはN個のsN $を持っており、このストリームをメイン$に追加しています。 s1$ +--1--------------------99---------------------> s2$ +------3--------7------------------------------> main$ +---[1]-[1, 3]---

1熱

2答えて

angular2：Obserable <Response> subscribeOnCompletedが

Imが、私はそのhttpリクエストにいくつかのサブスクライブを持っていると私は、すべてのサブスクライブが行われた後、機能を行うことができますしたい角度2. で要求を実行しようとしている。.. が定義されていません。 ot rxjsのドキュメントによると、subscribeOnCompletedは私が望む機能ですが、何らかの理由で私はメソッドが定義されていません。誰かがなぜアイデアを持っていますか

0熱

1答えて

RxAndroid間隔が二回の代わりに一度

CODE heartBeatSub = Observable.interval(HEARTBEAT_INTERVAL, TimeUnit.SECONDS) .flatMap(new Func1<Long, Observable<Notification<Response>>>() { @Override public Observable<Notifi

3熱

1答えて

rxjs Observablesを連結する

複数のオブザーバを連結することは可能ですか？例えば：私は3機能があります。よう Observable.combine (ensureUserLogged(), createEntity(), checkEntity()).subscribe ( checkEntityResult => console.log (checkEntityResult), error => con

0熱

2答えて

Angular2サービスが保持しているオブザーバブルを購読し、それを表示する必要があります。

serverがserver.ioからサーバーからデータを取得するtwitterストリームとフロントエンド角アプリケーションをリッスンするangle2 + nodejsアプリケーションを作成しています。この時点まではすべて動作しますが、socket.ioを使用してデータを取得する私のangular2サービスを購読する方法を見つけることができません。私のサービスが持っているデータを購読するにはどうした

1熱

2答えて

角2 - コンポーネントのObservablesを使用して他のコンポーネントに値を出力する

Observablesをコンポーネントで使用することが可能で、他のコンポーネントでサブスクライブできるかどうかは疑問です。 BugListComponent - コンポーネントがboot.tsに注入され、私はすべての私のサービスをロードするファイル指定（ブートストラップが置かれている場所） import {Subject, BehaviorSubject} from 'rxjs/Rx'; vi

0熱

1答えて

Observablesを延期する

メッセージを送信し、最終的に応答を受け取る標準WebSocketを使用しています。以前は$q.deferを使用し、遅延オブジェクトを保存して約束を返しました。レスポンスハンドラは、格納されている遅延オブジェクトをルックアップし、値を使用して解決します。これは観測可能で可能ですか？ // As part of the websocket setup websocket.onmessage =

2熱

1答えて

Angular2 Observerがなくなっている

私は観察者にこだわることができません。私は、オブザーバブルを作成するコンポーネントを持っており、コールバックでオブザーバを捕まえます。しかし、後で、私はそのオブザーバーを得ることができません - 私は別のインスタンスのコンポーネントを持っているかのように。例：私は別のコンポーネントからこれに加入している、と私はその最初のテスト値を得るか import {Component} from 'angu

1熱

1答えて

平坦化ネストされたObservables.subscribe

私はrx.jsとObservablesに新しいですし、私は次のコールバック地獄を平らにする方法を知りたいと思った： function getdata1 (argument) { return this.http.get(url) .map((res: Response) => res.json()); } function getdata2 (argument) {

1熱

1答えて

RxJava ObservableへのAPIコールバックのバインド

私は別のスレッドでネットワークソケットをリッスンする反応的なアプリケーションを作成しようとしていますが、Observableをどのようにして正確に構築するのかちょっと困惑しました。私が持っているインターフェイスの多くは、私が使用しているAPIによって制約されているため変更できません。私は以下のテストでしようとしていることを掘り下げましたが、getPriceReactive()メソッドの本体を記入す