首页 文章
  • 4 votes
     answers
     views

    没有ReactiveCrudRepository的WebFlux和Kotlin corountines

    我正在开发一个使用Kotlin,Spring Boot,Hibernate(所有最新版本)的项目,我想让它与Spring的WebFlux框架反应 . 问题是我不能使用 ReactiveCrudRepository 因为Web应用程序必须使用Oracle数据库,因此必须使用Hibernate . 所以我无法想出如何使用非阻塞访问Oracle SQL数据库(只有免费框架)的方法 . 我的问题是: 有可...
  • 0 votes
     answers
     views

    哪个CoroutineScope用于Spring Boot WebFlux endpoints

    在Spring Boot WebFlux应用程序中,我们有许多 endpoints (REST和GraphQL),它们返回 Mono 或 Flux 的某些内容 . 这些 endpoints 调用的代码都是非阻塞的,但是我们不想使用reactor,而是想使用Kotlin协程编写所有这些非阻塞代码 . 我们可以使用 kotlinx.coroutines.reactor.mono() 这样的方法将我们的...
  • 4 votes
     answers
     views

    Kotlin coroutine吞下例外

    关于异常处理如何与协同程序一起使用,我感到非常困惑 . 我希望有一个挂起函数链可以像同步代码一样在它们之间传递异常 . 因此,如果说Retrofit引发了IOException,我可以在挂起函数链的开头处理该异常,例如在演示者中向用户显示错误 . 我做了这个简单的例子来尝试协同程序但是如果我取消注释 throw Exception 在异常无法运行之后调用代码但是异常不会使应用程序崩溃 . pack...
  • 1 votes
     answers
     views

    将回调代码迁移到挂起的函数

    我正在使用协同程序将我的Android代码从Java重新分解为Kotlin,但我没有找到一种简单的方法来将基于回调的代码重写为暂停函数 . 一个基本的例子是一个返回结果的警告弹出窗口,在Javascript中它会是这样的: let value = prompt("please insert a value") console.log("Value:"+val...
  • 1 votes
     answers
     views

    Kotlin Coroutine逃脱了回调地狱

    我正在尝试使用Kotlin的协同程序来避免回调地狱,但在这种特殊情况下它看起来并不像我能想到的那样 . 我有这个SyncService类,它调用一系列不同的方法将数据发送到服务器,如下所示:SyncService调用Sync Student,它调用Student Repository,它调用DataSource,使服务器请求通过Apollo的Graphql Client发送数据 . 我的每个功能都...
  • 4 votes
     answers
     views

    如何使用suspendCoroutine将java 7将来转换为kotlin挂起函数

    在kotlin暂停函数中包装java 7期货的最佳方法是什么?有没有办法将返回Java 7期货的方法转换为挂起函数? 对于任意回调或java 8 completablefutures,该过程非常简单,如下所示:* https://github.com/Kotlin/kotlin-coroutines/blob/master/kotlin-coroutines-informal.md#suspend...
  • 2 votes
     answers
     views

    我如何在Kotlin写一系列的承诺?

    是否可以使用 only Kotlin编写一系列promise(或任务)? 例如,JavaScript中的序列承诺写为: const SLEEP_INTERVAL_IN_MILLISECONDS = 200; const alpha = function alpha (number) { return new Promise(function (resolve, reject) { ...
  • 0 votes
     answers
     views

    在主线程中运行非阻塞协同程序

    我们有一个特殊的用例,如果我们可以用Kotlin的协程来解决我们的问题,或者我们必须依赖CompletableFutures,我需要帮助才能找到答案 . 基本上,我们为单线程本身的服务器编写插件 . 这意味着,我们可以使用不同的钩子来添加逻辑,这个逻辑总是在主线程中运行,不能被阻塞 . 另外,在使用服务器的API时,我们必须在主线程内,因为给定的方法不是线程安全的 . 为了使用异步代码,我们've...
  • 4 votes
     answers
     views

    Kotlin协程和Spring Framework 5反应型

    Kotlin协程允许通过返回 Deferred 值来执行非阻塞代码 . 这对于在使用阻塞方法(例如来自库)时制作非阻塞代码非常有用 . Spring 5允许在框架中使用 Mono 和 Flux . 我看到的最大兴趣是能够序列化这两种类型的实例,并在有人调用控制器 endpoints 时将其作为响应发送回来 . Spring 5的一个重点是对Kotlin(路由器,bean声明......)有一个特...
  • 4 votes
     answers
     views

    带节点模块的Kotlin协同程序

    我问自己如何将Kotlin的协同程序与一些节点模块一起使用 . 我正在尝试在Kotlin中编写node.js服务器 . 继续使用JavaScripts着名的回调或Promises是很简单的,但看起来Kotlin回调将是更好的选择 . 但是对于node.js服务器,我需要使用MySQL或bcrypt库,只使用回调或Promise但不能使用协同程序,因为它不是分别用Kotlin编写的 . Kotlin...
  • 1 votes
     answers
     views

    Kotlin反应渠道:父母完成后,嵌套发布商将无法启动?

    在 kotlinx-coroutines-reactive 的Kotlin 1.3.11和v1.0.1中,我发现当 Publisher<Publisher<T>> 在某些内部发布者上调用 consumeEach 之前完成时,这些内部发布者在最终启动时根本不执行 . 这是预期的吗?考虑例如: publish { send(publish<Unit> { ...

热门问题