Merge pull request #1526 from RustedBones/connection-pool-settings-mi…

…n-connections-modifier Add minConnections modifier to ConnectionPoolSettings #1525
akka · Nov 14, 2017 · 50a9d32 · 50a9d32
2 parents d707ccb + 32d3a5a
commit 50a9d32
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/akka-http-core/src/main/scala/akka/http/javadsl/settings/ConnectionPoolSettings.scala b/akka-http-core/src/main/scala/akka/http/javadsl/settings/ConnectionPoolSettings.scala
@@ -31,6 +31,7 @@ abstract class ConnectionPoolSettings private[akka] () { self: ConnectionPoolSet
   // ---
 
   def withMaxConnections(n: Int): ConnectionPoolSettings = self.copy(maxConnections = n)
+  def withMinConnections(n: Int): ConnectionPoolSettings = self.copy(minConnections = n)
   def withMaxRetries(n: Int): ConnectionPoolSettings = self.copy(maxRetries = n)
   def withMaxOpenRequests(newValue: Int): ConnectionPoolSettings = self.copy(maxOpenRequests = newValue)
   def withPipeliningLimit(newValue: Int): ConnectionPoolSettings = self.copy(pipeliningLimit = newValue)

diff --git a/akka-http-core/src/main/scala/akka/http/scaladsl/settings/ConnectionPoolSettings.scala b/akka-http-core/src/main/scala/akka/http/scaladsl/settings/ConnectionPoolSettings.scala
@@ -31,6 +31,7 @@ abstract class ConnectionPoolSettings extends js.ConnectionPoolSettings { self:
 
   // overrides for more precise return type
   override def withMaxConnections(n: Int): ConnectionPoolSettings = self.copy(maxConnections = n)
+  override def withMinConnections(n: Int): ConnectionPoolSettings = self.copy(minConnections = n)
   override def withMaxRetries(n: Int): ConnectionPoolSettings = self.copy(maxRetries = n)
   override def withMaxOpenRequests(newValue: Int): ConnectionPoolSettings = self.copy(maxOpenRequests = newValue)
   override def withPipeliningLimit(newValue: Int): ConnectionPoolSettings = self.copy(pipeliningLimit = newValue)