reactivex

2熱

3答えて

私はUITableViewにデータを添付しようとしています。 http://yannickloriot.com/2016/01/make-uitableview-reactive-with-rxswift/：：私は、次の操作を実行しようと let currentQuestion: Variable<Taxi?> = Variable(nil) ：まず、私は次の変数を作成している私は、ここでは

2熱

1答えて

Observable.timeoutを使用してタイムアウトした後はどうなりますか？

Observable私はデータベースにアクセスし、いくつかの情報を問い合わせています。私は、このように、私が使用して、5秒よりも私の観察可能な実行が長くしたくない： myObservable.timeout(5,second); それから私はまた、このように私が使用してエラー通知を処理したい： myObservable.timeout(5,second).onError(return empt

3熱

1答えて

サブスクリプションを維持しながら観測可能なストリームを変更する

RxJSでは、ストリームが変更されてもサブスクリプションがストリームに残るようにしたい。 bar$流れを変えながら、私は動作をテストするために間隔ストリームを使用 //Works because foo$ is unchanged let foo$ = Rx.Observable.interval(1000); foo$.subscribe(x => console.log(`foo$: ${

3熱

1答えて

エラーが発生した後にObservableを再購読する

私はRxSwiftのハングアップを始めているように感じます。しかし、私はちょうどロードブロッキングを打ちました。デモ用に作成したオブジェクトです（私はSOに投稿する前に簡略化しました）。私の問題は、アップロードプロセス中にネットワークエラーが発生した場合、すべてのサブスクリプションが処分されることです。だから私が再びrightBarButtonItemをタップすると何も起こりません。これをモデ

2熱

1答えて

RxJava（ReactiveX）を使用してObservableを実行するにはどのくらいかかりましたか？

スカラPlay Framework 2.5でjava ReactiveX（RxJava）を使用して、非同期的にcouchbaseと通信しています。私のobservableを実行するのにどれくらいの時間がかかりましたか？私は、以下のコードを使用して私の観察可能なものを定義します。 def get(id: String) : Observable[Profile] = { this.buck

0熱

2答えて

RxSwiftを使用して手動でイベントを発行する（つまり、EventEmitterを作成する）方法を教えてください。

RxSwiftを使用してイベントエミッタを実装するにはどうすればよいですか？ Rxドキュメントとサンプルを使ってみると、私は完全なばかげた気分になり、手動でイベントを手動で発行する方法が非常に混乱していますオブザーバーからオブザーバブルまで。 Observableを購読しているすべてのObserverにデータでイベントを発行できるObservableがあることを理解しています。しかし、私はこれがS

3熱

2答えて

rxjs subscribe（）コールバック関数にオブジェクトを渡す方法は？

私はcordio-plugin-network-informationを使用してIonic2 Appを開発しています。私はapp.tsからconnectイベントとdisconnectイベントを購読しており、NavControllerとLoadingコンポーネントへの参照をsubscribe（）コールバックは、切断のイベントが発生するたびにUI上部にLoadingオーバーレイを表示することができます

7熱

3答えて

次イベントで値を必要としないObservableの優先タイプはありますか？

私はObservableを持っています。これは、トリガーにのみ使用されますflatMap/map。だから私はNextというイベントしか必要とせず、決して価値がない。私は自分のコンセプトをそのようなごみ箱の値に使うことができましたが、RxSwiftのコンベンションがあるかどうかは疑問です。ここでは、私が扱ってんだよ。この例では // I'd rather not have an Element t

0熱

1答えて

無視/フィルタリングなし

フィルタリングできる演算子はnilですか？私が来た最も近いがここに述べたソリューションです：https://github.com/ReactiveX/RxSwift/issues/209#issuecomment-150842686 関連抜粋：.notNil()後しかし public protocol OptionalType { func hasValue() -> Bool }

0熱

1答えて

木の後でObservableの最初の放射を取得する

不定期に値を放出するホットObservable<String> myObservableが与えられているとします。私はflatMapにできるようにしたいと思いますobs1Observableとobs1の私は初期myObservable値とflatMapobs2したい結果に応じて。例としては、以下のコードを考えてみます。 myObservable .flatMap(stringRes