reactivex

1熱

1答えて

私は観測値から値を受け取り、観測値を返す2つの関数に値をパイプする方法が必要です（単一の値を出してから終了する）。私は.combineLatest()が私に投影関数を渡すことを望んでいましたが、そうではありません。サンプルコード（動作しない）： const ac = [1, 2, 3]; // only as example, I have complex types in my array n

0熱

2答えて

RxJsでObservableからの放射が考えられますか？

クイック質問：エラーが発生した場合、.do()が撃退されますか？ドキュメンテーションは、「Observableソース上のすべての放出について副作用を実行するが、そのソースと同一のObservableを返す」と述べている。エラーも排出と考えられていますか？ return this.authHttp.get(url) .delay(5000) .map(this.extract

0熱

1答えて

連鎖したrxjs観測可能なオペレータ

ReactiveXの原理は比較的新しいですが、私はこれまでに学んだことの大ファンです。私はちょっと考えましたが、もっと経験豊かな意見を出したいと思います。 Observableを返すメソッドがいくつかあります。それぞれが似たような魔法の中にObservableを作り、同じ正確な演算子を連鎖させます。これらの演算子を抽象化して、それぞれのメソッドをこのコードで繰り返す必要はありません。たとえば、これ

1熱

1答えて

観測可能な配列から要素を選択する角度

私はAPIに問い合わせて、それが返す配列から特定の要素を取得しようとしています。私はAPIにクエリを実行し、JSON応答を返します。私は、numパラメータに一致する値Rnを持っている一つの要素を見つけるために、フィルタを呼び出したいT. に応じて、各オブジェクトをマップする関数に.MAP呼び出しによって getOne(num: number): Observable<T> { let

2熱

2答えて

すべてのエミッタされたストリームを集約し、rxJavaを使ってそれらをinmidiatlyで出力します。

私はデータページA, B, C, D...を放出するストリームを持っています。どのような演算子を使ってこのようなストリームを取得できますか：[A], [A, B], [A, B, C], [A, B, C, D]...？私はcollectまたはtoListを知っていますが、ストリームの最後に1回だけ送信します。

6熱

1答えて

IronPythonスクリプトの中からlambdaを使ってRx拡張メソッドを呼び出すことはできますか？

誰かこの本当に奇妙な観測を教えてもらえますか？私はIronPython内部からRx拡張メソッドを呼び出そうとしていましたが、それは単に不可能になっています。私はこの簡単な例に煮詰めました： import clr clr.AddReference("System.Core") from System.Linq import Enumerable def process(value):

8熱

1答えて

RxJava 2.0 - ObservableをPublisherに変換する方法

ObservableをRxJavaバージョン2のPublisherに変換するにはどうすればよいですか？最初のバージョンでは、私が必要とするものを正確に実行するhttps://github.com/ReactiveX/RxJavaReactiveStreamsプロジェクトがあります。しかし、RxJava 2でどうすればいいですか？

0熱

1答えて

rxswift：Observableを取得する方法<Any> Observable <[Category]>の組み合わせになりますか？

私のアプローチでは疑問があります。私が最初にすべての住宅を取得した後、家族をフェッチた観測をしたいと思っ //I can fetch from the server the houses and save them in the database func houses() -> Observable<[House]> //Given a houseId, I can fetch it's

-1熱

2答えて

マークメソッドを使用しないでください

私はいくつかのメソッドが呼び出されるべきではないことを示すためにJavaでいくつかの良い方法があるかどうか知りたいですか？私はもっと大きなチームで働いていると思っています。そして、このメソッドは決して呼び出されないので、テストしようとはしません。おそらくアサートはいいアイデアですか？コンテキスト：私はJavaでReactiveXを使用していますが、Observableは停止されず、onErr

0熱

1答えて

RxSwift 3.1 UITableViewデータソースが動作しない

私は新しいプロジェクトでCarthage経由でRxSwift 3.1（Galois）を使用しています。私はオンラインとドキュメントで見つかったいくつかの例を使ってデータをUITableViewにバインドしようとしました。実行した後、 class ChooseCityView: UIViewController, UITableViewDelegate { @IBOutlet weak