public class PoolFlow
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
PoolFlow.RequestContext |
static class |
PoolFlow.RequestContext$ |
static class |
PoolFlow.ResponseContext |
static class |
PoolFlow.ResponseContext$ |
Constructor and Description |
---|
PoolFlow() |
Modifier and Type | Method and Description |
---|---|
static akka.stream.scaladsl.Flow<PoolFlow.RequestContext,PoolFlow.ResponseContext,akka.NotUsed> |
apply(akka.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> connectionFlow,
ConnectionPoolSettings settings,
akka.event.LoggingAdapter log) |
public static akka.stream.scaladsl.Flow<PoolFlow.RequestContext,PoolFlow.ResponseContext,akka.NotUsed> apply(akka.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> connectionFlow, ConnectionPoolSettings settings, akka.event.LoggingAdapter log)