Skip to content
This repository has been archived by the owner on Sep 14, 2023. It is now read-only.

Commit

Permalink
Merge pull request #99 from VladKopanev/zio-1.0.0
Browse files Browse the repository at this point in the history
Bump version to zio 1.0.0
  • Loading branch information
VladKopanev authored Aug 5, 2020
2 parents 09d8773 + 46fcbc7 commit e4444ca
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 7 deletions.
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ test-output/
project/.sbt
test-output/
local.*
.idea

# if you are here to add your IDE's files please read this instead:
# https://stackoverflow.com/questions/7335420/global-git-ignore#22885996
Expand Down
6 changes: 3 additions & 3 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -89,9 +89,9 @@ lazy val core = project
name := "zio-saga-core",
crossScalaVersions := allScala,
libraryDependencies ++= Seq(
"dev.zio" %% "zio" % "1.0.0-RC20",
"dev.zio" %% "zio-test" % "1.0.0-RC20" % "test",
"dev.zio" %% "zio-test-sbt" % "1.0.0-RC20" % "test"
"dev.zio" %% "zio" % "1.0.0",
"dev.zio" %% "zio-test" % "1.0.0" % "test",
"dev.zio" %% "zio-test-sbt" % "1.0.0" % "test"
),
testFrameworks := Seq(new TestFramework("zio.test.sbt.ZTestFramework"))
)
Expand Down
9 changes: 5 additions & 4 deletions core/src/main/scala/com/vladkopanev/zio/saga/Saga.scala
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
package com.vladkopanev.zio.saga

import com.vladkopanev.zio.saga.Saga.Compensator
import zio.{ Cause, Exit, Fiber, IO, RIO, Schedule, Task, UIO, ZIO }
import zio.clock.Clock
import zio.{Cause, Exit, Fiber, IO, RIO, Schedule, Task, UIO, ZIO}

/**
* A Saga is an immutable structure that models a distributed transaction.
Expand Down Expand Up @@ -175,8 +176,8 @@ object Saga {
request: ZIO[R, E, A],
compensator: Compensator[R, E],
schedule: Schedule[SR, E, Any]
): Saga[R with SR, E, A] = {
val retry: Compensator[R with SR, E] = compensator.retry(schedule.unit)
): Saga[R with SR with Clock, E, A] = {
val retry: Compensator[R with SR with Clock, E] = compensator.retry(schedule.unit)
compensate(request, retry)
}

Expand Down Expand Up @@ -217,7 +218,7 @@ object Saga {
def retryableCompensate[R1 <: R, SR, E1 >: E](
c: Compensator[R1, E1],
schedule: Schedule[SR, E1, Any]
): Saga[R1 with SR, E1, A] =
): Saga[R1 with SR with Clock, E1, A] =
Saga.retryableCompensate(request, c, schedule)

def noCompensate: Saga[R, E, A] = Saga.noCompensate(request)
Expand Down

0 comments on commit e4444ca

Please sign in to comment.