Add capability for Pekko Streams

Author: mdedetrich

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 ++ vertx.projectRefs
+  core.projectRefs ++ ws.projectRefs ++ akka.projectRefs ++ pekko.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")
@@ -146,6 +146,20 @@ lazy val akka = (projectMatrix in file("akka"))
   )
   .dependsOn(core)
 
+ThisBuild / resolvers += "Apache Snapshots".at("https://repository.apache.org/content/repositories/snapshots/") // Remove once Pekko makes a proper release
+
+lazy val pekko = (projectMatrix in file("pekko"))
+  .settings(
+    name := "pekko"
+  )
+  .jvmPlatform(
+    scalaVersions = scala2alive ++ scala3,
+    settings = commonJvmSettings ++ Seq(
+      libraryDependencies += "org.apache.pekko" %% "pekko-stream" % "0.0.0+26621-44d03df6-SNAPSHOT" % "provided"
+    )
+  )
+  .dependsOn(core)
+
 lazy val armeria = (projectMatrix in file("armeria"))
   .settings(
     name := "armeria"

pekko/src/main/scala/sttp/capabilities/pekko/PekkoStreams.scala

@@ -0,0 +1,12 @@
+package sttp.capabilities.pekko
+
+import org.apache.pekko
+import pekko.stream.scaladsl.{Flow, Source}
+import pekko.util.ByteString
+import sttp.capabilities.Streams
+
+trait PekkoStreams extends Streams[PekkoStreams] {
+  override type BinaryStream = Source[ByteString, Any]
+  override type Pipe[A, B] = Flow[A, B, Any]
+}
+object PekkoStreams extends PekkoStreams