用解构代替.bind在Arrow Monad理解中不起作用

问题描述

根据Arrow的Javadoc，有三种绑定monad的方法：

/**
 * All possible approaches to running [Kind] in the context of [Fx]
 *
 * ```
 * fx {
 *   val one = just(1).bind() // using bind
 *   val (two) = just(one + 1) // using destructuring
 *   val three = !just(two + 1) // yelling at it
 * }
 * ```
 */

第一个和最后一个都可以正常工作，但是由于某种原因，销毁不能成功，为什么？

在下一个示例中，您可以看到我正在使用解构，val (j) = helloJoey().k(),) but that value is interpreted as a 单声道而不是字符串。

class HelloServiceImpl : HelloService {

    private val logger = LoggerFactory.getLogger(javaClass)

    override fun helloEverybody(): Mono<out String> {
        return MonoK.monad().fx.monad {
            val (j) = helloJoey().k()
            val a = !Mono.zip(helloJohn(),helloMary()).map { "${it.t1} and ${it.t2}" }.k()
            "$j and $a"
        }.fix().mono

    }

    override fun helloJoey(): Mono<String> {
        return Mono.defer {
            logger.info("helloJoey()")
            sleep(2000)
            logger.info("helloJoey() - ready")
            Mono.just("hello Joey")
        }.subscribeOn(Schedulers.elastic())
    }

    override fun helloJohn(): Mono<String> {
        return Mono.defer {
            logger.info("helloJohn()")
            sleep(5000)
            logger.info("helloJohn() - ready")
            Mono.just("hello John")
        }.subscribeOn(Schedulers.elastic())
    }

    override fun helloMary(): Mono<String> {
        return Mono.defer {
            logger.info("helloMary()")
            sleep(5000)
            logger.info("helloMary() - ready")
            Mono.just("hello Mary")
        }.subscribeOn(Schedulers.elastic())
    }

}

fun main() {
    val countDownLatch = CountDownLatch(1)
    HelloServiceImpl().helloEverybody().subscribe {
        println(it)
        countDownLatch.countDown()
    }
    countDownLatch.await()
}

解决方法

这是一个已知的问题，也是为什么我们不采用这种方法。它们被标记为已弃用的here。

会发生什么，MonoK是一个数据类，对于该数据类，已将解结构运算符定义为返回包装的Mono。当在fx块内使用时，此解构优先于BindSyntax上定义的解构。检查并提示您预期的类型是否有效，否则请使用invoke或bind。

arrow-kt kotlin kotlin kotlin