akka-http-handler/src/main/scala/com/softwaremill/sttp/akkahttp/package.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

package com.softwaremill.sttp

import akka.stream.scaladsl.Source
import akka.util.ByteString
import com.softwaremill.sttp.model.{BasicRequestBody, BodySerializer}

package object akkahttp {
  private[akkahttp] case object SourceBodySerializer
      extends BodySerializer[Source[ByteString, Any]] {
    def apply(t: Source[ByteString, Any]): BasicRequestBody =
      throw new RuntimeException("Can only be used with akka-http handler")
  }

  implicit val sourceBodySerializer: BodySerializer[Source[ByteString, Any]] =
    SourceBodySerializer
}