Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import scala.reflect.ClassTag
import scala.util.DynamicVariable

import org.apache.pekko
import pekko.actor.ActorSystem
import pekko.actor.{ ActorSystem, ClassicActorSystemProvider }
import pekko.http.scaladsl.Http
import pekko.http.scaladsl.client.RequestBuilding
import pekko.http.scaladsl.model._
Expand Down Expand Up @@ -224,8 +224,24 @@ trait RouteTest extends RequestBuilding with WSTestRequestBuilding with RouteTes
}
}
}
private[http] object RouteTest {
def runRouteClientServer(request: HttpRequest, route: Route, serverSettings: ServerSettings)(
object RouteTest {

/**
* Turn the route into a function for testing, but do not handle exceptions in any way, instead, they are bubbled
* out as is to the caller.
* @since 1.4.0
*/
def toFunctionPassThroughExceptions(route: Route)(
implicit system: ClassicActorSystemProvider): HttpRequest => Future[HttpResponse] = {
val routingLog = RoutingLog(system.classicSystem.log)
val routingSettings = RoutingSettings(system)
val parserSettings = ParserSettings.forServer
implicit val ec: ExecutionContextExecutor = system.classicSystem.dispatcher
implicit val mat: Materializer = SystemMaterializer(system).materializer
Route.createAsyncHandler(route, routingLog, routingSettings, parserSettings)
}

private[http] def runRouteClientServer(request: HttpRequest, route: Route, serverSettings: ServerSettings)(
implicit system: ActorSystem): Future[HttpResponse] = {
import system.dispatcher
for {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ object Route {
SystemMaterializer(system).materializer)
}

private def createAsyncHandler(sealedRoute: Route, routingLog: RoutingLog, routingSettings: RoutingSettings,
private[pekko] def createAsyncHandler(sealedRoute: Route, routingLog: RoutingLog, routingSettings: RoutingSettings,
parserSettings: ParserSettings)(
implicit ec: ExecutionContextExecutor, mat: Materializer): HttpRequest => Future[HttpResponse] = {
request =>
Expand Down