observable

11熱

1答えて

私は入力フィールドを持っており、ユーザーが検索文字列を入力すると、_heroService httpリクエストを行う前にユーザーが少なくとも300ミリ秒（debounce）の入力を待つことを望みます。変更された検索値のみがサービスに渡されます（distinctUntilChanged）。 switchMapは、これらの_heroServiceオブザーバブルを結合し、元のリクエスト順でそれらを再配置

7熱

3答えて

Android RxJava Observableで2つのクエリを順番に実行するにはどうすればよいですか？

私は2つの非同期タスクを実行したい。私はZIPやFlatについて何かを読んだことがありますが、私はそれをよく理解していませんでした。私の目的はローカルSQLiteからデータをロードすることです。終了すると、リモート）。誰かが私にそれを達成する方法を提案できますか？これは私が（単一のタスク）を使用していますRxJava観察可能なスケルトンです： // RxJava Observable

7熱

2答えて

RxJS Observablesでカウントダウンタイマーを作成する方法は？

Observablesを使用してカウントダウンタイマーを作成しようとしていますが、http://reactivex.io/documentation/operators/timer.htmlの例は機能していません。この特定の例では、timerIntervalに関連するエラーは、Observableの関数ではなく、timerから返されます。私も他のアプローチで実験してきたし、私が思い付くした最高の

5熱

1答えて

複数スレッドからの先物 - onNextから観測可能

Futuresのリストの結果からObservableをリアルタイムで生成したいと思います。私はFuture.sequenceで実行している先物のリストを持っていて、完了するたびに通知するObservableで進捗を監視しています。私は基本的に次のようにしています： def observeFuturesProgress(futs: List[Future[Int]]) : Observable[S

0熱

1答えて

同位体2角形

どのように私はangular2とobservablesとisotope jquety libを使用できますか？私はサーバーからデータを取得するときにアイソトープを適用したい。今の私が持っている： import {Component} from "angular2/core"; import {Heroes} from "./heroes"; import {ApiclientService}

3熱

2答えて

Angular2を使用したNTLM認証

クライアントWebアプリケーションでは、ntlmプロトコルを使用してサーバーで認証する必要があります。 $ httpサービスでAngular1を使用している間、ブラウザー（クロム、エッジ）は、ユーザーにユーザー名/パスワードの入力を促すことでNTLM認証の3つのステップすべてを実行していました。 Angular2では、Angular2に付属のhttpサービスを使用してブラウザ（クロム、エッジ）が4

5熱

1答えて

リスナーからデータを取得するためにオブザーバを実装するにはどうすればよいですか？

MaterialDrawerライブラリを使用してアプリ用の単純な引き出しを作成していますが、ライブラリ内のクラスのインスタンスの中には、呼び出されたときに渡される文字列が必要です。 IProfile profile = new ProfileDrawerItem().withName("John Doe"); withName()方法は、文字列を取り込み：例はIProfileクラスです。 Mate

5熱

2答えて

マルチスレッドコードでF＃イベントを使用

私はEvent＃を少し深く検討していましたが、F＃の非同期ワークフローとエージェントで多くの作業をしています。イベント< _>（）安全。ここで私はイベントを起こす共通の問題について話しているわけではありません。私は実際に購読し、イベントから削除/削除することについて話しています。テストの目的のために、私は let event = Event<int>() let sub = event.Publ

0熱

1答えて

RxScalalはマルチオブザーバーと契約しています

私はマルチを使用しようとしていますObserverObservableonNextループ内で発生しました。すべてのオブザーバーにとってうまくいかないようです。 import rx.lang.scala.Observable object SubscribeMultiEvent extends App{ val obv = Observable.apply[String]{ s =>

21熱

1答えて

Angular2 Observable - 処理する前にループ内のすべての関数呼び出しが終了するのを待つ方法

現在、Angular1で書かれているアプリケーションを移行することで、Angular2の知識を向上させようとしています。特に私の特徴は私を困惑させています。呼び出し元の関数が呼び出している関数が一連の約束を完了するまで、呼び出し関数が処理を待つ機能を複製しようとしています。角度1での機能は、私は基本的に、このようなルックスを呼び出しています： this.processStuff = functi