1回答
当为我的测试提供层时，我无意中发现了这种奇怪的行为，即不可能在一个值中提取这些层。
该代码编译：
def spec: ZSpec[environment.TestEnvironment, Any] =
suite("EnvironmentLoaderSuites")(
testM("the Config is correct") {
assertM(environmentLoader.bpfEnv())(
equalTo(expectedEnv))
}
).provi
浏览 6提问于2020-04-10得票数 0
回答已采纳
我知道这个错误：
[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回答
我有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
回答已采纳
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
回答已采纳
我有一堆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的方法：
def method(...): ZIO[Any with clock, SomeError, Unit]
调用此返回Task[Unit]的方法
def otherMethod(..): Task[Unit] = {
ZIO.effect(method(...))
}
问题是，当我用ZIO.effect调用它时，我没有得到结果。如何将ZIO转换为Task以获得结果？
浏览 2提问于2021-05-13得票数 3
回答已采纳
2回答
我有一个ZIO，看起来像这样：
ZIO[transactor.Transactor[Task], Serializable, String]
我需要断言这个字符串，也就是使用另一个普通字符串的ZIO。
，所以我的问题是：
如何使用ZIO中的字符串断言普通字符串，或者
我是否可以将字符串提升到相同的ZIO中，用这个ZIO断言它：
ZIO[transactor.Transactor[Task], Serializable, String]
我正在使用ZIO测试作为我的测试框架。
浏览 16提问于2022-09-01得票数 0
1回答
我使用ZLayer和Sttp Client(异步)来创建简单的http请求者应用程序，但我发现类型不匹配错误，我不能解决它。有人能告诉我为什么会出现类型不匹配错误吗？ 我使用这些版本的scala和库。 java -> 8.282.08.1-amzn scala -> s.13.5 dev.zio -> 1.0.7 com.softwaremill.sttp.client3 -> 3.3.0 type mismatch;
found : zio.ZLayer[sttp.client3.asynchttpclient.zio.SttpClient,Nothing,Z
浏览 26提问于2021-05-07得票数 1
在运行以下代码时，我得到了RejectedExecutionException：
override def run(args: List[String]): ZIO[zio.ZEnv, Nothing, ExitCode] = {
val test = for {
start <- ZIO effect Instant.now.toEpochMilli
loop = for {
f <- effectBlocking{Thread sleep 1000}
} yield ()
allFib <- l
浏览 1提问于2021-03-24得票数 0
我是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回答
我有这个方法
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
这可能是一个愚蠢的问题，但从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
回答已采纳
我对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
我正在用zio在scala.js上试用示例应用程序
一旦我将sbt版本从1.2.8更新到1.3.13或1.4.4，我就会得到以下错误：
[error] Referring to non-existent method java.time.LocalTime$.NANOS_PER_SECOND()long
[error] called from private java.time.LocalDateTime.plusWithOverflow(java.time.LocalDate,long,long,long,long,int)java.time.LocalDateTime
[error]
浏览 4提问于2020-11-29得票数 2
回答已采纳
我在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
1回答
我要学习zio图书馆的refineXXX。为此，我编写了简单的代码。
import zio.ZIOAppDefault
import zio.Unsafe.unsafe
import zio._
import java.sql.SQLException
object Bot extends ZIOAppDefault {
val codeWithExc: ZIO[Any,Throwable,Int] =
ZIO.fail(new SQLException("message of SQL error."))
val MainApp: ZIO[Any, Th
浏览 13提问于2022-10-03得票数 0
我有一个简单的应用程序：
import zhttp.http.*
import zhttp.http.Method.GET
import zhttp.service.Server
import zio.*
object HexAppApplication extends ZIOAppDefault {
// Create HTTP route
val app: HttpApp[Any, Nothing] = Http.collect[Request] {
case GET -> !! / "text" => Response.text("H
浏览 14提问于2022-04-19得票数 4
回答已采纳
我对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
回答已采纳
2回答
我正在学习ZIO2.x，当使用Runtime层配置bootstrap时，它不起作用。
object RuntimeCustom extends ZIOAppDefault {
// It's not work, And I don't know why?
override val bootstrap = EmailService.live
def run = (for {
_ <- ZIO.debug("Start...")
_ <- EmailService.send("God", "Hi
浏览 19提问于2022-10-01得票数 0
回答已采纳
2回答
我在IDEA (scala研讨会)中有下一个代码，
import zio.console.Console
import zio.{IO, Task, ZIO}
val st :Seq[Task[Int]] = Seq(Task(1),Task(2),Task(3))
val t : Task[List[Int]]= IO.collectAll(st)
val r : ZIO[Console, Throwable, List[Int]] = t
r.fold(
f => {
println(s"fail f=$f");
0
},
s =&
浏览 14提问于2019-11-07得票数 2
1回答
尝试学习使用ZIO库，所以我决定创建一个基本的web服务应用程序。Idea相当基本，使用http4s库作为服务器和路由端点，在端点调用上打印"hello world“。
在我找到的文档和示例的帮助下，生成代码：
object Main extends ManagedApp {
type AppEnvironment = Clock with Console with HelloRepository
type AppTask[A] = RIO[AppEnvironment, A]
override def run(args: List[String]): ZManaged
浏览 3提问于2019-10-24得票数 3
回答已采纳
scala如何用这个响应来代替val呢？
我已经得到了方法实现，我如何才能重构它的产量结构
case Method.GET -> !! / "leagues" =>
val openDotaResponse: ZIO[Client, Throwable, Response] = Client.request("https://api.opendota.com/api/leagues")
val bodyOfResponse: ZIO[Client, Throwable, String] = openDotaResponse.flatMap(_
浏览 9提问于2022-11-29得票数 0
回答已采纳
由于Excel行的限制，下面的代码被限制为大约100万行：
ZStream.unwrap(generateStreamData).mapMPar(32) {m =>
streamDataToCsvExcel
}
一切都很简单，而且运作得很完美。我跟踪流的行数，然后停止写入数据。但是，我想中断在mapMPar中生成的所有子纤维，如下所示：
ZStream.unwrap(generateStreamData).interruptWhen(effect.true).mapMPar(32) {m =>
streamDataToCsvExcel
}
不幸的是，这一进程立即在这里中断。
浏览 8提问于2022-01-28得票数 0
我需要处理一组Ids并以zio.Task[ListRelevantReadingRow]的形式返回结果
def getBaselinesForRequestIds(baseLineReqIds: Set[String]): Task[List[RelevantReadingRow]] =
dynamoConnection
.run(
table.getAll("baseline_req_id" in baseLineReqIds)
)
.flatMap(_.toList.separate match {
case (err :
浏览 5提问于2022-03-16得票数 2
回答已采纳
1回答
下面是我的脚本：
zio=build-mac-zio
x="zio"
y=${!x}
当我尝试echo $y时，我得到了预期的build-mac-zio。但是，当我执行此命令时：
mkdir -p $JENKINS_URL/bkp/jobs/$y/builds/
我得到以下消息：
-bash: build-mac-zio: command not found
如何访问$y并将其赋值给其他变量。
浏览 2提问于2015-11-12得票数 0
我使用ZIO 2和ZIO与普通的测试容器-scala。
测试结果如下：
object MongoRepositorySpec extends ZIOSpecDefault:
object TestLayers:
val mongoTestcontainer: ZLayer[Any, Throwable, MongoDBContainer] =
ZLayer.scoped(
ZIO.acquireRelease {
ZIO
.attempt(DockerImageName.parse("mongo:4.
浏览 8提问于2022-09-26得票数 2
我知道ZIO维护自己的堆栈，即zio.internal.FiberContext#stack，它保护递归函数，如
def getNameFromUser(askForName: UIO[String]): UIO[String] =
for {
resp <- askForName
name <- if (resp.isEmpty) getNameFromUser(askForName) else ZIO.succeed(resp)
} yield name
从堆栈溢出。但是，它们仍然占用ZIO解释器堆栈中的空间，这可能导致OutOfMemoryError进
浏览 8提问于2019-12-04得票数 4
回答已采纳
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
回答已采纳
我想试一试ZIO，但我有一个类似于此的异常家族
trait MyException extends Exception {
def errorCode: Int
}
，返回Future[Either[MyException, A]]的函数和我遇到的问题是将它们转换为ZIO。例如：
def foo(): Future[Either[MyException, A]] = ???
def process(): ZIO[Any, MyException, Unit] =
ZIO
.fromFuture(_ => foo())
.flatMap(ZIO.fromEit
浏览 4提问于2022-03-18得票数 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。因此，我希望使用zio.ZStream来操作fs2流的数据。如何将StreamIO，Int转换为ZStream与猫互操作？
import zio.stream.ZStream
import zio.stream.interop.fs2z._
import cats.implicits._
import zio.interop.catz.core._
import zio.interop.catz._
val a: Stream[IO, Int] = ???
val b: Stream[Pure, Int] = ???
浏览 7提问于2021-12-19得票数 0
假设我有一个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回答
我是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
回答已采纳
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
回答已采纳
我刚刚开始研究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
回答已采纳
2回答
scala.js可以与scala ZIO一起使用吗？我希望在scala.js中使用scala ZIO，我只知道如何在普通应用程序中使用scala ZIO，有人知道如何在scala.js中使用它吗？
浏览 13提问于2019-01-23得票数 5
回答已采纳
1回答
我使用ZIO的第一步是尝试将这个readfile函数转换为兼容的ZIO版本。
下面的代码片段可以编译，但我不会在ZIO版本中关闭源代码。我该怎么做？
def run(args: List[String]) =
myAppLogic.exitCode
val myAppLogic =
for {
_ <- readFileZio("C:\\path\\to\file.csv")
_ <- putStrLn("Hello! What is your name?")
name <
浏览 0提问于2021-03-19得票数 1
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
回答已采纳
我想创建一个目录，然后对该目录做一些操作，最后删除它。为此，我使用了一个括号中的习语。
val fs: FileSystem = ???
val path = ???
ZIO.bracket[Any, Throwable, Path, Unit](
acquire = ZIO{fs.mkdirs(path); path},
release = p => ZIO.succeed(fs.delete(p, true)),
use = p => ZIO{()})
删除目录显然是一个容易出错的操作。但是release函数必须总是成功的。所以我不得不使用ZIO.suc
浏览 8提问于2019-08-02得票数 4
回答已采纳
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
回答已采纳
我正在尝试构建一个集成了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
回答已采纳
1回答
在ZIO中在效果中执行效果
、、、、
所以我用ZIO编写了一个简单的程序，它会询问用户的名字，然后简单地问候他/她。
object PrintName extends App {
val askName: ZIO[Any, Throwable, ZIO[Console, IOException, Unit]] = for {
name: String <- ZIO.effect(StdIn.readLine())
} yield (putStrLn(s"Hello $name"))
override def run(args: List[String]): URIO[ZEnv, ExitC
浏览 4提问于2022-04-27得票数 0
2回答
我刚刚开始评估ZIO以改进编程模型和异步Scala代码的性能。在我的代码库中，我经常处理Future[Option[T]]，到目前为止，我已经使用Scalaz的OptionT monad转换器来处理这个问题。现在我想用ZIO试试这个。
考虑两项职能：
def foo: String => Future[Option[T]]和def bar: T => Future[U]
我试过这样的方法：
val t = for {
o: Option[Int] <- ZIO.fromFuture { implicit ec =>
foo("
浏览 23提问于2020-04-05得票数 1
回答已采纳
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
回答已采纳
我试图用jdbc连接到oracle java，但问题是我得到了无效路径的错误！！它显示了url中的一个空白，但实际上我并没有给出一个指向java的链接，而是一个长的oracleJdbcUrl，如下所示：
"jdbc:oracle:thin:@" +
"(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)" +
"(HOST=myoracle.db.server)(PORT=1521))" +
"(CONNECT_DATA=(SERVICE_NAME=my_servicename)))";
但是我在控
浏览 8提问于2022-07-06得票数 0
回答已采纳
使用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
回答已采纳
1回答
我必须创建Scala库，它应该被划分为核心模块和包含其他特性的模块(比如zio核心和zio流)。我的想法是把他们放在单独的github回购，但在不同的子项目。我该怎么做？我必须单独发布这些模块吗？他们能有不同的版本吗？
另外，我还不清楚库用户是否应该只包括“功能模块”，后者将临时包含核心模块。同样，这意味着在ZIO情况下，我只能包含zio流，并且我可以使用zio核心。
浏览 1提问于2022-01-19得票数 0
在getstarted zio文档页面中有这个trivial exemple，但我无法运行它，有什么简单的代码可以让这个代码片段工作(有问题并能够在控制台中回答)？ import zio.console.{getStrLn, putStrLn}
object Bug41 {
def main(args: Array[String]): Unit = {
println("Start")
val program =
for {
_ <- putStrLn("Hello! What is your name?&#
浏览 42提问于2021-01-14得票数 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
回答已采纳
这是我的模特课：
final case class Organization(
id: UUID,
name: String
)
我的查询类如下所示：
case class Queries(
organizations: URIO[DatabaseService, List[Organization]]
)
我有一个类似这样的服务：
class GraphQLService:
def getOrganizations =
for
db <- ZIO.service[DatabaseService]
浏览 14提问于2022-09-20得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
