ZIO测试中的“测试正在使用时间，但不会提前测试时钟”
是指在ZIO测试框架中，可以模拟时间的流逝，但不会提前模拟时钟的变化。
在软件开发中，时间相关的功能和逻辑是很常见的，例如定时任务、超时处理、时间戳等。在进行单元测试时，我们需要对这些时间相关的功能进行测试，以确保其正确性和稳定性。
ZIO是一个功能强大的纯函数式编程库，提供了一种简洁而强大的方式来处理异步和并发任务。ZIO测试框架是ZIO库的一部分，专门用于测试ZIO程序。
在ZIO测试中，我们可以使用TestClock来模拟时间的流逝。TestClock是一个可变的时钟，可以手动控制时间的前进。通过使用TestClock.adjust方法，我们可以将时间向前或向后调整指定的时间量。
然而，需要注意的是，尽管我们可以模拟时间的流逝，但ZIO测试框架不会提前模拟时钟的变化。这意味着，当我们在测试中调整时间后，时钟并不会立即变化，而是在下一次时间相关的操作中才会生效。
这种设计决策是为了确保测试的可靠性和一致性。如果测试框架提前模拟时钟的变化，可能会导致测试结果与实际运行结果不一致，从而影响测试的准确性。
总结起来，ZIO测试中的“测试正在使用时间，但不会提前测试时钟”意味着我们可以模拟时间的流逝，但时钟的变化会在下一次时间相关的操作中生效，以确保测试的可靠性和一致性。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云函数计算（云原生、服务器运维）：https://cloud.tencent.com/product/scf
- 腾讯云数据库（数据库）：https://cloud.tencent.com/product/cdb
- 腾讯云对象存储（存储）：https://cloud.tencent.com/product/cos
- 腾讯云人工智能（人工智能）：https://cloud.tencent.com/product/ai
- 腾讯云物联网（物联网）：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发（移动开发）：https://cloud.tencent.com/product/mobdev
- 腾讯云区块链（区块链）：https://cloud.tencent.com/product/baas
- 腾讯云音视频（音视频、多媒体处理）：https://cloud.tencent.com/product/vod
相关·内容
1回答
我在测试我的第一个ZIO+HTTP4S应用程序时遇到了问题。测试挂起，没有完成。
我的应用程序(简化)的代码是
object Main extends App {
def server: ZIO[AppEnvironment, Throwable, Unit] =
for {
(...)
fullApp <- ZIO.runtime[AppEnvironment].flatMap { implicit rts =>
BlazeServerBuilder[AppTask](ec)
.bindHttp(api.po
浏览 0提问于2022-06-09得票数 1
回答已采纳
我知道这个错误：
[error] found : zio.ZIO[x.AppEnvironment,Throwable,Unit]
[error] (which expands to) zio.ZIO[zio.clock.Clock with zio.blocking.Blocking with x
.ApplicationResources,Throwable,Unit]
[error] required: zio.ZIO[zio.clock.Clock with zio.blocking.Blocking,Throwabl
浏览 2提问于2019-10-02得票数 0
回答已采纳
1回答
我找不到任何关于如何忽略套件或使用ZIO测试进行测试的内容。 无论是在示例中还是在文档中(https://zio.dev/docs/usecases/usecases_testing) test package object中有一个ignored /**
* Creates an ignored test result.
*/
final val ignored: ZTest[Any, Nothing, Nothing] =
ZIO.succeed(TestSuccess.Ignored) 但是如何在您的代码中使用它呢？ 我尝试了不同的方法，但都没有成功。
浏览 10提问于2019-12-23得票数 3
回答已采纳
3回答
单元测试时间限制代码
、、、
我目前正在开发一个应用程序，它可以执行很多时间限制的操作。也就是说，基于long now = System.currentTimeMillis();，并结合调度程序，它将计算将某些操作的执行参数化的时间段。例如：
public void execute(...) { // executed by an scheduler each x minutes
final int now = (int) TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis());
final int alignedTime = now - no
浏览 0提问于2012-07-09得票数 8
回答已采纳
1回答
我是ZIO和ZIO测试的新手，我想测试我在ZIOv1.0.0RC 17下编写的调度服务：
服务部门：
import zio.{RIO, Schedule}
import zio.clock.Clock
import zio.duration._
trait ModuleA {
def moduleA: ModuleA.Service
}
object ModuleA {
trait Service {
def schedule(arg: Int): RIO[Clock, Unit]
}
}
trait ModuleALive extends ModuleA {
浏览 3提问于2020-03-29得票数 1
回答已采纳
我正在开发ubuntu，我想看看哪个NTP是默认的，例如。史考利！如果它的配置是为了在另一个应用程序的集群中实现正确的时间同步。那么，我如何知道哪个NTP是在linux-ubuntu操作系统上配置的呢？
提前感谢
浏览 0提问于2021-03-22得票数 0
回答已采纳
1回答
我遇到过一些类似于解决我的问题的帖子，但它们都没有真正给出我想要的答案。我正在使用多点连接在两个设备之间进行连接，并且我希望在完全相同的时间执行一段代码，并且具有尽可能少的延迟。我已经完成了从主机向另一个对等体发送时间戳的过程，以便同时启动计时器(使用Date类)，但总会有至少0.3到0.5秒的延迟。问题是设备时间没有完全同步。有没有第三方框架或解决方案可以让我同时在两个设备上运行代码？这方面的一个例子是应用程序AmpMe，它可以在许多设备上同步音乐。顺便说一下，我用的是Swift 3。
浏览 16提问于2017-07-11得票数 4
1回答
我正在努力学习时间表是如何工作的，我只想使用时间表向控制台显示一条简单的消息。
import zio.console._
import zio._
import scala.util.Try
import zio.duration._
import zio.clock._
object MyApp extends zio.App {
def run(args: List[String]) =
myAppLogic.exitCode
val myAppLogic =
for {
sequential = Schedule.recurs(10) andTh
浏览 2提问于2021-04-04得票数 0
回答已采纳
1回答
我刚开始在Scala中使用ZIO。我使用ZIO的Gen类型编写了一些Scalacheck风格的测试，它们似乎可以工作，但我想手动测试REPL中的生成器，以确保它们实际上正在生成我希望它们生成的数据。
问题是: ZIO中的所有内容都封装在ZIO monad中，我需要将正确的数据传递到这个monad中，以打开它并查看结果。在REPL中没有说明如何做到这一点的文档。
我想我理解如何为一个没有环境依赖的基本程序:调用zio.Runtime.default.unsafeRun。但是Gen对象需要一个Random with Sized类型的环境，我不知道如何生成这种环境的实例。
给定一个Gen[Rando
浏览 3提问于2021-07-10得票数 1
我正在使用MSSQL 2005。
我有StringIO对象，它包含了zip文件内容。
以下是如何获得zip二进制数据：
stringio = Zip::ZipOutputStream::write_buffer do |zio|
Eclaim.find_by_sql("SET TEXTSIZE 67108864")
zio.put_next_entry("application.xml")
#zio.write @claim_db[:xml]
biblio = Nokogiri::XML(&
浏览 3提问于2012-05-13得票数 2
回答已采纳
我是Actors的新手，尝试使用类型层次结构和状态实例来执行简单的乒乓示例。我完全跟踪了zio演员的微站点，并对程序代码做了一些更新。我在./src/main/resources/application.conf的配置文件如下所示：
testSystemOne.zio.actors.remoting {
hostname = "127.0.0.1"
port = 8055
}
testSystemTwo.zio.actors.remoting {
hostname = "127.0.0.1"
port = 8056
}
和MyApp.scala：
浏览 1提问于2020-07-21得票数 0
回答已采纳
1回答
在使用时，我们不能在不使用zio.Clock的测试中进行竞赛。影响不会被打断。有办法解决这个问题吗？
package zio.spark.effect
import zio._
import zio.test.TestAspect.timeout
import zio.test._
object WeirdClocks extends DefaultRunnableSpec {
def wait(seconds: Int): UIO[Int] = UIO(Thread.sleep(seconds * 1000)).as(seconds)
override def spec: Z
浏览 8提问于2022-03-05得票数 0
回答已采纳
我想完全在ZIO堆栈上编写一个应用程序。我是这个框架的新手，所以也许解决方案是微不足道的，我误解了一些重要的东西。并面临以下问题。我需要取消订阅卡夫卡主题与命令收到的休息。另外，我也需要通过REST订阅主题。我使用zio-kafka编写了以下代码来描述订阅主题并打印事件到控制台的效果：
private val consumerSettings = ConsumerSettings(List("localhost:9092")).withGroupId("MyConsumerGroup")
.withOffsetRetrieval(OffsetRetrie
浏览 1提问于2021-09-17得票数 0
回答已采纳
关于zio-grpc双流关闭调用的咨询:何时关闭？我正在使用grpcurl来测试bistream，但是zio-grpc服务器端不会太快地关闭(过一段时间就会关闭)。
我正在通过Stream.ensuring观看grpc服务器端流关闭事件。详情如下：
请求流的：通过forkDomaen在光纤中使用请求流:我假设如果流关闭，grpc请求流将被关闭。
request
.mapM { reqItem =>
// do action here
UIO(println(s"test get some data from request item: ${
浏览 13提问于2022-10-17得票数 0
回答已采纳
我对ZIO中的异常处理有一个误解。我跟踪了。
在测试类中，我运行以下代码：
new DefaultRuntime {}.unsafeRun(
(for {
peopleRef <- Ref.make(Vector(People()))
_ <- people(2).provide(Test(peopleRef)) // this throws the exception
} yield ())
.fold(
err =>
err shouldBe ServiceException(&#
浏览 1提问于2019-10-20得票数 3
回答已采纳
假设我有一个IO操作(因此不安全)，它将返回true或false。我希望使用Zio调度机制来执行这个操作，直到值为true为止，但最多只能执行N次。采用来自的代码并将其更改为我想要实现的.
import zio._
import zio.duration._
import zio.console._
import zio.clock._
import java.util.Random
object API {
// our API method will return true about 30% of the time, but
// return false the rest o
浏览 5提问于2020-11-20得票数 1
回答已采纳
1回答
增强型xp时钟漂移
、、、
我正在使用嵌入在我的机器上的Windows，它是从备份映像安装的。最近，我在我的机器上发现了一个系统时钟漂移。这种漂移非常大(每5分钟一秒钟)。这种漂移不是永久性的，它在每次启动时都会随机发生。但是，如果该单位启动与漂移，它将停留到下一次启动。另一件重要的事情是，在启动时，单元每次以0延迟开始，例如：
启动部队。
世界时间是12:00，单位时间是12:00。
等10分钟。
世界时间是12:10:00，单位时间是12:09:58.00。
关掉这个装置
启动部队。
世界时间是12:15:00.00，单位时间是12:15:00。
时钟不能同步。
我安装了常规XP
浏览 2提问于2012-12-24得票数 0
我尝试在代码中直接获取JSON，然后将其转换为Avro，以编写一个kafka主题。
下面是我的case类代码：
import zhttp.http._
import zio._
import zhttp.http.{Http, Method, Request, Response, Status}
import zhttp.service.Server
import zio.json._
import zio.kafka._
import zio.kafka.serde.Serde
import zio.schema._
case class Experiments(experimentId
浏览 15提问于2022-10-21得票数 0
1回答
我有这个方法
import ClientServer.*
import zio.http.{Client, *}
import zio.json.*
import zio.http.model.Method
import zio.{ExitCode, URIO, ZIO}
import sttp.capabilities.*
import sttp.client3.Request
import zio.*
import zio.http.model.Headers.Header
import zio.http.model.Version.Http_1_0
import zio.stream.*
浏览 6提问于2022-12-03得票数 0
2回答
我有一个ZIO，看起来像这样：
ZIO[transactor.Transactor[Task], Serializable, String]
我需要断言这个字符串，也就是使用另一个普通字符串的ZIO。
，所以我的问题是：
如何使用ZIO中的字符串断言普通字符串，或者
我是否可以将字符串提升到相同的ZIO中，用这个ZIO断言它：
ZIO[transactor.Transactor[Task], Serializable, String]
我正在使用ZIO测试作为我的测试框架。
浏览 16提问于2022-09-01得票数 0
我有一个简单的用于理解的代码：
def nameFormatter(request: SomeRequest) : FormattedData = {
for {
config <- ZIO.fromOption(configuration.get(request.name)).orElseFail( new Exception("Unknown config"))
name = config.data.name.pipe(SomeName)
} yield FormattedData(
name,
浏览 4提问于2021-09-22得票数 1
1回答
我正在尝试在ZIO中使用TrampolineExecutionContext，以便在同一线程上测试后台流订阅(这样我就可以按照我期望的顺序运行effect )。 testM("Using trampoline execution context") {
(for {
queue <- Queue.unbounded[String]
_ <- ZStream
.fromQueue(queue)
.take(1)
.foreach(el => ZIO.effe
浏览 20提问于2020-09-12得票数 1
回答已采纳
我有一堆IO，所有这些都可能成功或失败：
val result: Seq[IO[MyFailure, MySuccess]] = ...
我需要总结一下结果，这样我才能一起检查所有的失败和成功。
case class MySummary(failures: Seq[MyFailure], successes: Seq[MySuccess])
def makeSummary(results: Seq[IO[MyFailure, MySuccess]]): UIO[MySummary] = ???
起初，这似乎与foreach非常相似，但仔细观察，我发现这在这里没有帮助。对于Future，我通常使
浏览 13提问于2021-12-28得票数 3
回答已采纳
我正在学习ZIO，使用库zio-streams的1.0.9版本。我找不到任何引用来显示ZSink和ZTransducer之间的区别。
有什么关系？
浏览 1提问于2021-07-11得票数 3
回答已采纳
使用Radisson，只需接收事件就足以向列表中添加新项。为此，您需要执行以下操作：
object Test extends App {
val redisson = Redisson.create()
val events = redisson.getQueue[String]("minio_events", new StringCodec())
events.addListener(new ListAddListener() {
override def onListAdd(o: String): Unit = println(o)
})
}
当它需
浏览 55提问于2021-06-03得票数 0
回答已采纳
2回答
我正在使用ZIO：
在我的build.sbt
"dev.zio" %% "zio" % "1.0.0-RC9"
无论我尝试什么，每次我需要它们的时候，我的结果都会被计算出来：
val t = Task {
println(s"Compute")
12
}
val r = unsafeRun(for {
tt1 <- t
tt2 <- t
} yield {
tt1 + tt2
})
println(r)
对于此示例，日志如下所示：
Comp
浏览 12提问于2019-07-09得票数 3
1回答
我有10个请求 val reqTemplate = quickRequest.post(uri"http://localhost:8280/delay/1")
val requests = for {i <- 1 to 10} yield {
reqTemplate.body(s"{test:$i}")
} 如何同时发送这些请求？ 我试过了 val responseTasks = reqs.map(SttpClient.send)
val allResponsesTask: Task[List[Response[String]
浏览 58提问于2020-04-02得票数 1
回答已采纳
我想测试以下函数：
def curl(host: String, attempt: Int = 200): ZIO[Loggings with Clock, Throwable, Unit]
如果环境只使用标准的ZIO环境，如Console with Clock，测试将开箱即用：
testM("curl on valid URL") {
(for {
r <- composer.curl("https://google.com")
} yield
assert(r, isUnit))
}
测试
浏览 11提问于2020-02-04得票数 1
回答已采纳
1回答
调用rpc方法之间的功能
、、、、
我试图修改ZIO的以适应我想要的，但遇到了一个问题。我想在不同的rpc调用之间实现功能，但我似乎无法让它工作，因为在下面的示例中，只执行while循环、rcpMethod3()和rcpMethod4()，而rcpMethod1()和rcpMethod2()不执行。
我想要执行所有的rcpMethod和while循环。
object Client extends App {
val clientLayer: Layer[Throwable, ClientZLayer] =
ClientZLayer.live(
ZManagedChannel(
ManagedChann
浏览 2提问于2021-11-30得票数 0
回答已采纳
1回答
有一个简单API的例子，它使用ZIO效果返回None或Option[String]。我使用ZIO调度来运行效果，只要返回None，但限制在一定次数内。该示例基于来自的代码
import zio._
import zio.random._
import zio.duration._
import zio.console.{Console, putStrLn}
import zio.Schedule
import scala.util.{Random => ScalaUtilRandom}
object RecordAPI {
def randomId(length: Int):
浏览 8提问于2020-11-30得票数 2
回答已采纳
import org.slf4j.LoggerFactory
import zio.blocking.Blocking
import zio.clock.Clock
import zio.console.{Console, putStrLn}
import zio.kafka.consumer.{CommittableRecord, Consumer, ConsumerSettings, Subscription}
import zio.kafka.consumer.Consumer.{AutoOffsetStrategy, OffsetRetrieval}
import zio.kafka.
浏览 11提问于2022-06-29得票数 1
回答已采纳
1回答
我有一个简单的程序，或多或少是一个下载器。它收集一个或多个可配置的资源(通过自定义协议)，聚合和写入它们的位置。
这个程序看起来很简单，但是代码仍然很复杂，并且混合了函数代码和过程代码(来自我的Java背景)。我想简化它，并转到一个功能齐全的。我正在读关于ZIO的文章，整个画面开始在我的脑海中浮现。
然而，在阅读了入门和概述之后，我仍然有一些问题。
主要流程可能是：
for {
config <- Configuration.parse(args)
resources <- Downloaders.download(config)
_ <-
浏览 0提问于2019-12-02得票数 1
回答已采纳
6回答
重置源文件更改的检测
、、、、
有时，我不得不编写将计算机时钟向前移动的代码。在这种情况下，某些.cpp或.h文件的最新修改日期设置为未来时间。
后来，当我的时钟固定后，我编译了我的源代码，系统重新构建了项目的大部分，因为一些最新的修改日期是在未来。每次后续的重新编译都有相同的问题。
我知道的解决方案是：
a)找到具有未来时间的文件并重新保存。这种方法并不理想，因为该项目非常大，即使是windows高级搜索也需要时间来查找已更改的文件。
b)删除整个项目，重新从svn中检出。
有人知道我如何解决这个问题吗？
在visual studio中是否有一个设置可以让我告诉编译器使用存档位而不是上次修改日期来检测源文件的更改？
或者可
浏览 11提问于2008-09-13得票数 0
回答已采纳
嗨，我创造了一个闪光灯游戏使用土坯闪光播放器6(空气)。如果我用“测试场景”来测试它，它会运行得很好。我将其设置为在Adobe桌面目标3.2 (我的PC为4.0)上运行，我以.air格式发布游戏并创建证书。
问题:我不能在我的电脑上安装我的游戏(在空气中)。
警告是:由于安装程序文件损坏，应用程序无法安装。尝试从应用程序作者获得一个新的安装程序文件。
我已经使用了管理员帐户，但它不起作用。你能帮我吗？
浏览 2提问于2014-03-04得票数 0
我刚刚开始研究ZIO，试图改进我的Scala。首先，我尝试更新我的一些旧代码。我已经包装了一些遗留代码，这些代码返回一个以选项包装的配置，并将其转换为ZIO，然后用于理解。
代码按预期工作，但如果返回None，则会得到：
Fiber failed.
A checked error was not handled.
None
Fiber:Id(1612612180323,1) was supposed to continue to:
a future continuation at tryzio.MyApp$.run(MyApp.scala:94)
a future continuat
浏览 2提问于2021-02-06得票数 1
回答已采纳
我对Scala和ZIO有些陌生，遇到了一些奇怪的谜团。
我希望设置一个包含ZIO队列的ZIO环境，并在以后具有与这个共享队列不同的ZIO任务offer和take。
我试着像这样定义我的环境
trait MainEnv extends Console with Clock
{
val mainQueue = Queue.unbounded[String]
}
并从以下不同的任务访问队列
for {
env <- ZIO.environment[MainEnv]
queue <- env.mainQue
浏览 4提问于2019-10-01得票数 5
回答已采纳
我的目标是在一个数据集上运行多个spark ml回归模型(1000次)，我想使用zio而不是future来实现这一点，因为它运行得太慢了。下面是使用Future的工作示例。键的不同列表用于筛选键上的已分区数据集，并在其上运行模型。我已经设置了一个包含8个执行器的线程池来管理它，但它的性能很快就会下降。 import scala.concurrent.{Await, ExecutionContext, ExecutionContextExecutorService, Future}
import java.util.concurrent.{Executors, TimeUnit}
import
浏览 13提问于2020-04-28得票数 1
回答已采纳
2回答
scala
、、、
我对并行编程和ZIO很陌生，我试图通过并行请求从API中获取数据。
import sttp.client._
import zio.{Task, ZIO}
ZIO.foreach(files) { file =>
getData(file)
Task(file.getName)
}
def getData(file: File) = {
val data: String = readData(file)
val request = basicRequest.body(data).post(uri"$url")
.heade
浏览 2提问于2020-07-05得票数 0
回答已采纳
我从服务器发送了一个时间戳，我想让浏览器知道确切的时间。
我正在使用Moment，但我觉得有几种方法可以实现这一点。
我看过在setInterval()中使用isSame()，但它似乎不起作用。
var interval = setInterval(function(){
if(moment().isSame(moment(data.server_time_stamp))){
console.log('MATCHES!!!')
clearInterval(interval)
}
}, 1)
其中data.server_time
浏览 38提问于2018-01-13得票数 0
回答已采纳
我正在尝试使用ZIO 2中的Cats Mongo实现()。ZIO 2的文档()中有一章是如何将猫的资源转换为ZManaged的。
但在ZIO 2中，使用作用域而不是使用ZManaged是可行的。如何实现该转换？
这是猫的资源：
def catsEmbeddedMongo[F[_]: cats.effect.Async]: Resource[F, MongoClient[F]] = MongoClient.fromConnectionString[F]("mongodb://localhost:27017")
浏览 20提问于2022-08-08得票数 2
回答已采纳
我正在尝试构建一个集成了ZIO和http4s的服务。
起点是 (它使用zio 1.0.1，http4s 0.21.3，Scala2.12.11)
我能够使用sbt构建下面的代码，没有任何问题，但是在试图使用Bazel构建代码时遇到了麻烦：
import org.http4s.HttpRoutes
import org.http4s.dsl.Http4sDsl
import org.http4s.implicits._
import org.http4s.server.blaze._
import zio._
import zio.interop.catz._
import zio.intero
浏览 3提问于2020-09-03得票数 4
回答已采纳
val askNameFlatMap: ZIO[Console, IOException, Unit] = putStrLn("What is your Name? ") *>
getStrLn.flatMap(name => putStrLn(s"Hello $name"))
val askNameFor: ZIO[Console, IOException, Unit] = {
val getName: ZIO[Console, IOException, String] = getStrLn
for {
_ &
浏览 7提问于2022-04-27得票数 0
回答已采纳
有没有人有一个基本的zio-grpc服务器，在这个项目中也有codegen，与Scala 3一起工作？
我从他们回购的HelloWorld项目开始，并试图用scalaVersion := "3.1.0“构建它
以下是plugins.sbt中的相关部分：
libraryDependencies ++= Seq(
"com.thesamet.scalapb.zio-grpc" % "zio-grpc-codegen_2.13" % zioGrpcVersion,
"com.thesamet.scalapb" % "compil
浏览 6提问于2022-01-10得票数 0
回答已采纳
2回答
我有最后一个无标记DSL来构建简单的数学表达式：
trait Entity[F[_]] {
def empty: F[Int]
def int(value: Int): F[Int]
}
trait Operation[F[_]] {
def add(a: F[Int], b: F[Int]): F[Int]
}
我想实现一个ZIO解释器。基于module-pattern ，可能的实现如下所示：
type Entity = Has[Entity[UIO]]
object Entity {
val test: ULayer[Entity] =
ZLayer.succe
浏览 6提问于2020-12-07得票数 0
回答已采纳
1回答
尝试掌握ZIO
、、
我只是在尝试学习URIO，一切都很顺利，直到我得到了一个Seq[URIO[Any, Fiber.Runtime[Throwable, Unit]]] --我真的不确定该怎么做--我的纤维都没有运行，可能是因为我需要评估每个URIO，但如果是这样的话，我该如何在zio.App中做到这一点？我尝试过在序列上进行映射，但似乎总是以Seq[Nothing]结束…… 我已经尝试过在效果中包装Seq，但这似乎对我没有帮助。我已经看了ZIO网站上的示例，但它们不处理纤维列表，所以现在我迷路了…… 编辑 好的--我想我的问题是:如何运行效果列表？ package testmesomemore
import
浏览 14提问于2021-08-04得票数 1
回答已采纳
这可能是一个愚蠢的问题，但从ZIO开始，我无法将Seq[ZIO]转换为ZIO[Seq]。
def translate(keys: Seq[String], locales: Seq[Locale]):RIO[Translator, Seq[Translation]] = {
for {
service <- ZIO.environment[Translator]
} yield {
// service.translate produce a zio.Task[Translation]
keys.map(k => service.translate(
浏览 2提问于2021-04-28得票数 3
回答已采纳
我已经和合作了几个星期了，我真的很享受它。偶尔我会遇到一个令我沮丧的问题。当我遇到编译错误时，它就会启动。我刷新，并看到(极好的)发挥！错误信息。下面是一个简单的例子。
我转到适当的文件，修复错误，然后重新加载页面。然后我得到这个编译器错误：
奇怪的是，它显示了更新的源代码和错误修复，但是它从上一条消息中抛出了相同的编译器错误。如果我重新开始演出的话！服务器，然后所有的编译和我可以继续按预期，但当然是一个伟大的事情之一的发挥！能够编辑.java源文件并立即在浏览器中看到这些更改。
会真的很感激任何人的提示，谁曾遇到这件事，或有一个线索，是什么原因！非常感谢！我在运行OSX10.6。
浏览 3提问于2011-06-30得票数 3
我在Scala2.13/ Mill项目中使用。
这里的例子是：
@accessible
@mockable
trait AccountObserver {
val accountObserver: AccountObserver.Service[Any]
}
object AccountObserver {
trait Service[R] {
def processEvent(event: String): ZIO[R, Nothing, Unit]
}
// autogenerated `object Service { ... }`
// autogene
浏览 6提问于2019-10-29得票数 0
我对Sbt有个奇怪的问题。我将Scala zio版本设置为1.0.12 in build.sbt
val zio = "1.0.12"
但是，当我使用sbt运行应用程序时，它在2.x (屏幕)版本中下载了zio：
我不知道为什么。我从用户目录中删除了.ivy2和.sbt目录。我多次重新启动intellij，无效缓存。即使有了清晰的项目，它也总是下载版本2.0.0。使用此版本检查整个代码。
其他zio与我使用的lib版本有关：
val scalaVersion = "2.13.8"
val zio = "
浏览 3提问于2022-05-31得票数 0
1回答
我正在尝试使用0.15.0版本的库zio-kafka向Kafka主题生成一些消息。 显然，我对ZIO生态系统的理解是次优的，因为我不能产生一个简单的消息。我的程序如下： object KafkaProducerExample extends zio.App {
val producerSettings: ProducerSettings = ProducerSettings(List("localhost:9092"))
val producer: ZLayer[Blocking, Throwable, Producer[Nothing, String, Stri
浏览 15提问于2021-08-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
