Use with ZIO
Setup
You will need these dependencies
- sbt
libraryDependencies ++= Seq( "uk.gov.nationalarchives" % "da-sns-client_2.13" % "0.1.123", "dev.zio" % "zio-interop-cats_2.13" % "23.0.0.5" )
- Maven
<dependencies> <dependency> <groupId>uk.gov.nationalarchives</groupId> <artifactId>da-sns-client_2.13</artifactId> <version>0.1.123</version> </dependency> <dependency> <groupId>dev.zio</groupId> <artifactId>zio-interop-cats_2.13</artifactId> <version>23.0.0.5</version> </dependency> </dependencies>
- Gradle
dependencies { implementation "uk.gov.nationalarchives:da-sns-client_2.13:0.1.123" implementation "dev.zio:zio-interop-cats_2.13:23.0.0.5" }
Examples
import software.amazon.awssdk.services.sns.model.PublishResponse
import uk.gov.nationalarchives.DASNSClient
import zio.Task
import zio.interop.catz._
import io.circe.generic.auto._ // Used to provide Encoder[T] but you can provide your own
val snsClient = DASNSClient[Task]()
val topicArn = "topicArn"
case class Message(value: String)
val publishFn: Message => Task[PublishResponse] = snsClient.publish(topicArn)
val responses: Task[List[String]] = for {
res1 <- publishFn(Message("message1"))
res2 <- publishFn(Message("message2"))
} yield List(res1.messageId(), res2.messageId())