blob: 0357dd8188f898d709e5432284153627ce8475be (
plain) (
blame)
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
}
|