如何在Java中轻松使用Kotlin频道生成器？

Question

作为开发新API工作的一部分，我正在学习使用静态编程语言。最初我希望静态编程语言API在Java（Android）项目中使用，但从长远来看，我希望完全采用静态编程语言。

作为改进长期运行流程实现的一部分，我想使用协程。具体来说，来自kotlinx.coroutines包的通道生产者。

例如：

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

在Java中使用它的最佳方式是什么？我可以向Kotlin和/或Java添加临时“helper”函数。

Answer 1

目前，假设使用了Java 8并且lambda可用，我依赖于Kotlin中定义的助手函数，该函数允许传递回调以使用传入的结果。

Kotlin中的助手方法：

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

然后在Java中作为以下内容使用：

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

解释返回单元的原因。在这个答案中可以找到需要的实例。

Answer 2

与Java交互通道的最简单方法是通过反应流。Rx和项目Reactor都是开箱即用的。例如，将kotlinx-coroutines-rx2添加到依赖项中，您将能够使用rxFlowable构建器：

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

此函数返回一个可流动的实例，该实例是专门为从Java易于使用而设计的，例如，您可以在Java中执行以下操作：

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