問題タブ [reactivex]

こちらの質問 39 と同様の例に従ってください: http://reactivex.io/learnrx/

search(query: String)メソッド呼び出しを一連の呼び出しに変換しようとしています。私がこれを達成する方法は、メソッドが呼び出されるたびVariableに値で更新する を作成することです。querysearch(query: String)

それから私は私の中にこれを持っていますinit():

と入力する"ABC"と、メソッドが, , でsearch(query: String)3 回呼び出されます。それはwithにマッピングされます。次に、それを Facebook 検索 (Facebook で名前で人を検索する) にマッピングしています。そして、私は名前を印刷します。を使用しない場合、期待どおりに動作し、クエリ ( 、、 )ごとに 1 つずつ、3 セットの結果が得られます。"A""AB""ABC"seq(["A", "AB", "ABC"])queryVariable.asObservable()subscribeNexttakeUntil"A""AB""ABC"

しかし、(Facebook が要求に応答する前に) すばやく入力すると、 query に対して 1 つの結果のみが必要になります"ABC"。を追加したのはそのためtakeUntilです。facebookSearch(query: String)それを使用すると、次の呼び出しが行われたときに呼び出しが無視されると予想queryされますが、現在のクエリではキャンセルされているため、takeUntil何も出力されません。

これは既知の問題ですか、それとも何か間違っていますか?

UITableView にデータを添付しようとしています。ここでプロジェクト フォームをダウンロードし、データが tableView に添付されているコードを使用しています: http://yannickloriot.com/2016/01/make-uitableview-reactive-with-rxswift/ :

まず、次の変数を作成しました。

次に、次のことを試みます。

しかし、次の警告が表示されます: 'Extra argument in call' on the line .bindTo. 新しいセルを追加しようとしましたが、同じ結果が得られました。関係あるかわかりませんが、セル登録しました。

引数の型が一致しない場合にこの警告が表示される可能性があることをここで読みました: Swift - Extra Argument in call。ただし、引数はうまく一致しているようです。

私は Rx を初めて使用するので、誰かがここで何がうまくいかないのかを理解するのを手伝ってくれることを願っていました. ありがとう。

======

編集

これが私の新しいコードです。rx_itemsWithCellIdentifier("ChoiceCell")私は一人で試しましたrx_itemsWithCellIdentifier("ChoiceCell", cellType: ChoiceCell.self)：

私が利用した場所（タクシー）は、タクシーアイテムの配列です。下の図を参照してください。

また、.asObservable() を呼び出すと、次のようになります。

行を削除して、これらを印刷することができました.bindTo。その行を追加すると、以前と同じエラーが発生します。

重要: 以前にリンクした記事のコード ベースをいじってみました。ChoiceCell から削除すると、同じエラーを再現できます。

flatMap/のトリガーにのみ使用される Observable がありmapます。したがって、Nextイベントのみが必要であり、値は必要ありません。このようなゴミの値に独自の概念を使用できますが、RxSwift の規則があるかどうか疑問に思っています。

これが私が扱っているものです：

この例でtriggeringObservableは、ライブラリ内のいくつかのプロパティにあり、呼び出す準備ができてrx_observerいることを知らせてくれます。username()

フィルタリングできる演算子はありますnilか？私が最も近いのは、ここで言及されているソリューションです: https://github.com/ReactiveX/RxSwift/issues/209#issuecomment-150842686

関連する抜粋:

ただし、 after .notNil(),Eはまだオプションであるため、後続の連鎖演算子はwhereがオプションselfとして表示されます。したがって、次のことを行う追加の演算子が必要です。Observer<E>E

私は何かが欠けているに違いない。これは、非常に一般的なニーズのようです。

データベースにアクセスしてObservable、いくつかの情報を照会します。オブザーバブルが 5 秒以上実行されたくないので、次を使用します。

次に、エラー通知も処理したいので、次を使用します。

myObservable次に、データベース クエリを実行するために使用されるコードはどうなるのだろうか。それも終了しますか、それとも実行し続けますか? （これはJavaネイティブに起こりますFuture.get(timeLimit)）

RxJS では、ストリームが変更された場合でも、サブスクリプションがストリームに保持されるようにします。以下では、間隔ストリームを使用して動作をテストしました

jsbin ライブデモ

bar$ストリームの変更中にサブスクリプションを維持するにはどうすればよいですか? bar$ を変更した後、サブスクリプションを破棄して別のサブスクリプションを設定する必要がありますか?

RxSwift のコツをつかみ始めたような気がしますが、障害物にぶつかりました。デモ用に作成したオブジェクトを次に示します (SO に投稿する前に簡略化しました)。私の問題は、アップロード プロセス中にネットワーク エラーが発生すると、すべてのサブスクリプションが破棄されることです。そのため、もう一度タップしてrightBarButtonItemも何も起こりません。

これをモデル化する正しい/より良い方法は何ですか? PublishSubjectsの使い方がよくわからない!

そしてViewController.swift...

scala Play Framework 2.5 で Java ReactiveX (RxJava) を使用して、couchbase と非同期的に通信しています。オブザーバブルの実行にかかった時間を知りたいですか? 以下のコードを使用してオブザーバブルを定義します。

私は以下を使用してそれを呼び出します

オブザーバブルの実行にかかった時間をどのように測定できますか?

よろしくお願いします

フランシス

RxSwift を使用してイベント エミッターを実装するにはどうすればよいですか? (サブスクライブしている他のオブジェクトによって消費されるデータを発行できるオブジェクト。)

Rx のドキュメントと例を読んだ後、私は完全な馬鹿のように感じ、Observer から Observable に手動でイベントを発行する方法についてまだ非常に混乱しています。そのObservableにサブスクライブしているすべてのObserverにデータを含むイベントを発行できるObservableがあることを理解しています。ただし、これが実際に Swift でどのように実装されているかについてはまったくわかりません。

私が実装しようとしているものの例を次に示します。

そして2番目のファイル：

私の脳は揚げられています。これがどのように機能するかを明らかに誤解しているため、今のところ EmitterKit のような特殊なライブラリに切り替えるだけです。

しかし、Rx がどのように機能するかを理解する必要があります。ヘルプ！