rx-kotlin

2熱

1答えて

私は、Reactive Programming with RxJavaのバージョン2ではなく、バージョン1を対象とした例を使って作業しています。無限ストリームの紹介には、次の例があります。並行性）： Observable<BigInteger> naturalNumbers = Observable.create(subscriber -> { Runnabler =() -> {

2熱

1答えて

RxKotlin collectInto（）メソッドリファレンスを使用するMutableList

次のコードは、RxJavaの例をKotlinに変換しようとしています。 MutableListにIntの束を集めることになっていますが、いくつかのエラーが発生します。 val all: Single<MutableList<Int>> = Observable .range(10, 20) .collectInto(::MutableList, MutableList::a

1熱

1答えて

RX Observableを動的に更新する方法は？

（RxKotlinとRxJavaでの作業が、簡単のためにメタコードを使用して）多くReactive Extensionsガイドは、既に利用可能なデータからObservableを作成することから始めます。 The introduction to Reactive Programming you've been missingから、今outStream生み出す単純なフィルタを、考える人口リスト va

0熱

1答えて

コンストラクタとコンパニオンオブジェクトをインジェクトします

私はKotlinには新しく、値を注入しようとしています（この例ではIntですが、実際のコードではProviderクラスです）私は何をしていますかここで間違っている？なぜxは未解決の参照ですか？ class Test @Inject constructor(private val x: Int) { companion object { var y: Int = 0

0熱

5答えて

kotlin Androidを使用してURLからJSONを読み取る方法は？

アプリケーションを開発するためにkotlinを使用しています。今、私はサーバーからJSONデータを取得したいと思います。では、UMLからJSONを読み込むためにAsynaskとRxjavaを実装しました。またGoogleで検索していますが、私の要求には適切な詳細が得られません。 kotlinを使用してURLからJSONを読み取るにはどうすればよいですか？

0熱

2答えて

RxKotlinを使用するときにRxJavaのバージョンを指定する方法は？

GitHubのRxKotlinリポジトリ内のドキュメントに、最新のRxJavaのバージョンnに明示的に依存する方法が指定されていません。私たちは図書館のbuild.gradleファイルが表示されている場合、それはのようになりましたcompile 'io.reactivex.rxjava2:rxjava:2.1.0' を使用しています。しかし、我々は、最新のRxJavaのリリースではなく、ライブラ

-2熱

1答えて

Rxjava with kotlin

kotlinでrxjava 2を使用していますが、どのように解決すればいいですか？ var emailField = name.textChanges().skipInitialValue().toFlowable(BackpressureStrategy.LATEST) var passField = password.textChanges().skipInitialValue().toFl

1熱

1答えて

式として使用されるKotlin関数の場合、操作して値を返す簡潔な方法はありますか？

Kotlinでは、関数の最後のステートメントを戻り値として解釈できます。次の例のような状況を簡略化して冗長にすることはできますか？ { text: String -> val validated = validateText(text) if (validated) { actOnValidation() } validated } 私はこ

1熱

1答えて

RxKotlin flattenAsObservable（）：タイプは、メソッド参照

とのミスマッチ私はKotlinにいくつかのJavaコードを変換していると私はflattenAsObservable() といくつかの問題を抱えているがここでのコードは、Javaでのように見えたものです： discogsInteractor.search(query) .map(RootSearchResponse::getSearchResults) .flattenAsObs

0熱

1答えて

RxAndroid、Observableが放出を完了したかどうかを検出する方法

firebaseデータベースから保存された食品のリストを取得するために次のコードスニペットを作成し、そのリストを使用すると、firebaseデータベースから個々の食品の詳細を再度取得します。次のコードはうまく動作しますが、第2フラットマップに最初のフラットマップの発光が完了したことを知る方法がわかりません（すべてのフードリストが処理されました）。だから私はonCompleted()メソッドを呼び