Merge pull request #275 from tdroxler/feature/vertx-streams

Add `VertxStreams`

Author: adamw

build.sbt

@@ -75,7 +75,7 @@ val commonNativeSettings = commonSettings ++ Seq(
 )
 
 lazy val allProjectRefs =
-  core.projectRefs ++ ws.projectRefs ++ akka.projectRefs ++ armeria.projectRefs ++ fs2ce2.projectRefs ++ fs2.projectRefs ++ monix.projectRefs ++ zio1.projectRefs ++ zio.projectRefs
+  core.projectRefs ++ ws.projectRefs ++ akka.projectRefs ++ armeria.projectRefs ++ fs2ce2.projectRefs ++ fs2.projectRefs ++ monix.projectRefs ++ zio1.projectRefs ++ zio.projectRefs ++ vertx.projectRefs
 
 lazy val projectAggregates: Seq[ProjectReference] = if (sys.env.isDefinedAt("STTP_NATIVE")) {
   println("[info] STTP_NATIVE defined, including sttp-native in the aggregate projects")
@@ -245,3 +245,15 @@ lazy val zio = (projectMatrix in file("zio"))
     settings = commonNativeSettings
   )
   .dependsOn(core)
+
+lazy val vertx = (projectMatrix in file("vertx"))
+  .settings(
+    name := "vertx"
+  )
+  .jvmPlatform(
+    scalaVersions = List(scala2_12, scala2_13) ++ scala3,
+    settings = commonJvmSettings ++ Seq(
+      libraryDependencies += "io.vertx" % "vertx-core" % "4.4.0"
+    )
+  )
+  .dependsOn(core)

vertx/src/main/scala/sttp/capabilities/vertx/VertxStreams.scala

@@ -0,0 +1,12 @@
+package sttp.capabilities.vertx
+
+import io.vertx.core.buffer.Buffer
+import io.vertx.core.streams.ReadStream
+import sttp.capabilities.Streams
+
+trait VertxStreams extends Streams[VertxStreams] {
+  override type BinaryStream = ReadStream[Buffer]
+  override type Pipe[A, B] = ReadStream[A] => ReadStream[B]
+}
+
+object VertxStreams extends VertxStreams