reactive-aws-clients

ScalaAWS

• AWS SDK for Java V2
• AWS ClientScala
  • Java SDK(Consumer)
• Java
  • JavaScala(AsScala)
• Scala
  • core
    • scala.concurrent.Future
  • monix
    • monix.eval.Task
    • monix.reactive.Observable
  • cats-effect
    • cats.effect.IO
  • akka-stream
    • akka.stream.scaladsl.Source
    • akka.stream.scaladsl.Flow

• Java SE 8
• Scala
  • 2.11.x
  • 2.12.x
  • 2.13.x

build.sbt

val libraryName = "..." // e.g.) dynamodb
val version = "1.1.5"

libraryDependencies += Seq(
  "com.github.j5ik2o" %% s"reactive-aws-$libraryName-core" % version,
  "com.github.j5ik2o" %% s"reactive-aws-$libraryName-monix" % version, // optional
  "com.github.j5ik2o" %% s"reactive-aws-$libraryName-akka" % version, // optional
  "com.github.j5ik2o" %% s"reactive-aws-$libraryName-cats" % version, // optional
)

dynamodb

import com.github.j5ik2o.reactive.aws.dynamodb._
import com.github.j5ik2o.reactive.aws.dynamodb.implicits._ // 
import software.amazon.awssdk.services.dynamodb.model._
import software.amazon.awssdk.services.dynamodb.{ DynamoDbAsyncClient => JavaDynamoDbAsyncClient }

val underlying = JavaDynamoDbAsyncClient
  .builder()
  // ...
  .build()
val client = DynamoDbAsyncClient(underlying) // Java
val putItemRequest = PutItemRequest // Java
  .builder()
  .tableName(tableName)
  .itemAsScala(
    Map[String, AttributeValue](
      "Id"   -> AttributeValue.builder().s("abc").build(),
      "Name" -> AttributeValue.builder().s("xyz").build()
    )
  ) // Scala
  .build()
val putItemResponseFuture = client.putItem(putItemRequest)

(mvnInstall Maven)

$ sbt mvnClean mvnInstall // 
$ sbt compile