add Java Duration version of withResponseEntitySubscriptionTimeout

Author: pjfanning

http-core/src/main/scala/org/apache/pekko/http/impl/settings/ConnectionPoolSettingsImpl.scala

@@ -80,6 +80,9 @@ private[pekko] final case class ConnectionPoolSettingsImpl(
     copy(connectionSettings = f(connectionSettings),
       hostOverrides = hostOverrides.map { case (k, v) => k -> v.withUpdatedConnectionSettings(f) })
 
+  override def withResponseEntitySubscriptionTimeout(newValue: java.time.Duration): ConnectionPoolSettings =
+    withResponseEntitySubscriptionTimeout(newValue.asScala)
+
   /** INTERNAL API */
   private[http] def copyDeep(
       mapHostOverrides: ConnectionPoolSettings => ConnectionPoolSettings,

http-core/src/main/scala/org/apache/pekko/http/javadsl/settings/ConnectionPoolSettings.scala

@@ -109,6 +109,12 @@ abstract class ConnectionPoolSettings private[pekko] () { self: ConnectionPoolSe
   @ApiMayChange
   def withResponseEntitySubscriptionTimeout(newValue: Duration): ConnectionPoolSettings
 
+  /**
+   * Java API
+   * @since 1.3.0
+   */
+  def withResponseEntitySubscriptionTimeout(newValue: java.time.Duration): ConnectionPoolSettings
+
   def withTransport(newValue: ClientTransport): ConnectionPoolSettings =
     withUpdatedConnectionSettings(_.withTransport(newValue.asScala))
 }