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 Summary
Constructors -
Method Summary
Modifier 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
-
CustomTransport
public CustomTransport()
-
-
Method Details
-
connectTo
public 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:
connectTo
in interfaceClientTransport
-
in
-
out
public org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString> out() -
promise
-