blob: 53fe63ec0e862f71ed3526839be2d2d93869862c (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
package com.softwaremill.sttp.streaming
import akka.NotUsed
import akka.actor.ActorSystem
import akka.stream.Materializer
import akka.stream.scaladsl.Source
import akka.util.ByteString
import com.softwaremill.sttp.{ForceWrappedValue, SttpHandler}
import com.softwaremill.sttp.akkahttp.AkkaHttpSttpHandler
import scala.concurrent.Future
class AkkaStreamingTests(actorSystem: ActorSystem)(
implicit materializer: Materializer)
extends TestStreamingHandler[Future, Source[ByteString, Any]] {
override implicit val handler: SttpHandler[Future, Source[ByteString, Any]] =
AkkaHttpSttpHandler.usingActorSystem(actorSystem)
override implicit val forceResponse: ForceWrappedValue[Future] =
ForceWrappedValue.future
override def bodyProducer(body: String): Source[ByteString, NotUsed] =
Source.single(ByteString(body))
override def bodyConsumer(stream: Source[ByteString, Any]): Future[String] =
stream.map(_.utf8String).runReduce(_ + _)
}
|