JavaでKotlinチャネルプロデューサを簡単に使用するには？

Question

新しいAPIの開発の一環として、私はKotlinを使うことを学んでいます。当初はKotlin APIをJava（Android）プロジェクト内で使用したいと思っていましたが、長期的にはKotlinを完全に採用したいと考えています。

長期実行プロセスの実装の改善の一環として、私はコルーチンを使用したいと思います。具体的には、kotlinx.courtinesパッケージのchannel producerです。例えば

：

fun exampleProducer() = produce { 
    send("Hello") 
    delay(1000) 
    send("World") 
} 

Javaでこれを消費するための最良の方法は何ですか？私はKotlinやJavaに一時的な「ヘルパー」機能を追加することで大丈夫です。

Answer 1

Javaでチャネルを相互運用する最も簡単な方法は、リアクティブストリームを経由する方法です。 RxとProject Reactorの両方がすぐにサポートされています。たとえば、あなたのdependiciesにkotlinx-coroutines-rx2を追加し、rxFlowableビルダーを使用することができます：

fun exampleFlowable() = rxFlowable<String> { 
    send("Hello") 
    delay(1000) 
    send("World") 
} 

この機能は、特に、たとえば、使いやすさJavaからのために設計された、Flowableのインスタンスを返し、あなたはJavaで行うことができます：

exampleFlowable().subscribe(t -> System.out.print(t)); 

Answer 2

現在、Java 8が使用され、ラムダが利用可能であると仮定すると、コールバックを渡して受信結果を消費することを許可するヘルパー関数をKotlinに依存します。

Kotlinにおけるヘルパーメソッド：return Unit.INSTANCEがcan be found in this answer必要な理由について

ApiKt.exampleProducerCallback(text -> { 
    System.out.print(text); 
    return Unit.INSTANCE; // Needed since there is no void in Kotlin. 
}); 

説明：

fun exampleProducerCallback(callback: (String) -> Unit) = runBlocking { 
    exampleProducer().consumeEach { callback(it) } 
} 

。これは、その後のようにJavaで消費されています。