org.apache.pekko.http.impl.engine.client

Class PoolInterface.PoolInterfaceStage

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext>,PoolInterface>

org.apache.pekko.http.impl.engine.client.PoolInterface.PoolInterfaceStage

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext>,PoolInterface>

Enclosing interface:

PoolInterface

public static class PoolInterface.PoolInterfaceStage
extends org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext>,PoolInterface>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M>

Constructor Summary

Constructors

Constructor and Description
PoolInterfaceStage(PoolId poolId, PoolMaster master, int bufferSize, org.apache.pekko.event.LoggingAdapter log)

Method Summary

Modifier and Type	Method and Description
scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,PoolInterface>	createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)
scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,PoolInterface>	createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes, org.apache.pekko.stream.Materializer _materializer)
org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext>	shape()

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, async, async, getAttributes, initialAttributes, named, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

PoolInterfaceStage

public PoolInterfaceStage(PoolId poolId,
                          PoolMaster master,
                          int bufferSize,
                          org.apache.pekko.event.LoggingAdapter log)

Method Detail

createLogicAndMaterializedValue

public scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,PoolInterface> createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext>,PoolInterface>

createLogicAndMaterializedValue

public scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,PoolInterface> createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes,
                                                                                                                 org.apache.pekko.stream.Materializer _materializer)

Overrides:

createLogicAndMaterializedValue in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext>,PoolInterface>

shape

public org.apache.pekko.stream.FlowShape<PoolFlow.ResponseContext,PoolFlow.RequestContext> shape()