Class NewConnectionPoolSpec.ClientTransportTestSetup.CustomTransport
java.lang.Object
org.apache.pekko.http.impl.engine.client.NewConnectionPoolSpec.ClientTransportTestSetup.CustomTransport
- All Implemented Interfaces:
- ClientTransport
- Enclosing class:
- NewConnectionPoolSpec.ClientTransportTestSetup
public class NewConnectionPoolSpec.ClientTransportTestSetup.CustomTransport
extends Object
implements ClientTransport
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString, scala.concurrent.Future<Http.OutgoingConnection>> connectTo(String host, int port, ClientConnectionSettings settings, org.apache.pekko.actor.ActorSystem system) in()org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString>out()scala.concurrent.Promise<scala.Tuple3<String,Object, ClientConnectionSettings>> promise()
- 
Constructor Details- 
CustomTransportpublic CustomTransport()
 
- 
- 
Method Details- 
connectTopublic org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString, connectToscala.concurrent.Future<Http.OutgoingConnection>> (String host, int port, ClientConnectionSettings settings, org.apache.pekko.actor.ActorSystem system) - Specified by:
- connectToin interface- ClientTransport
 
- 
in
- 
outpublic org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString> out()
- 
promise
 
-