This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch 1.3.x
in repository https://gitbox.apache.org/repos/asf/pekko-http.git
The following commit(s) were added to refs/heads/1.3.x by this push:
new de61d2b0a add Java Duration version of
withResponseEntitySubscriptionTimeout (#789)
de61d2b0a is described below
commit de61d2b0a269499be88943c40ba23a5c86495b77
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Sep 25 04:42:52 2025 +0100
add Java Duration version of withResponseEntitySubscriptionTimeout (#789)
* add Java Duration version of withResponseEntitySubscriptionTimeout
* Update java-duration-support-javadsl.excludes
---
.../1.3.x.backwards.excludes/java-duration-support-javadsl.excludes | 1 +
.../pekko/http/impl/settings/ConnectionPoolSettingsImpl.scala | 3 +++
.../apache/pekko/http/javadsl/settings/ConnectionPoolSettings.scala | 6 ++++++
3 files changed, 10 insertions(+)
diff --git
a/http-core/src/main/mima-filters/1.3.x.backwards.excludes/java-duration-support-javadsl.excludes
b/http-core/src/main/mima-filters/1.3.x.backwards.excludes/java-duration-support-javadsl.excludes
index 201a40d36..7b44d7832 100644
---
a/http-core/src/main/mima-filters/1.3.x.backwards.excludes/java-duration-support-javadsl.excludes
+++
b/http-core/src/main/mima-filters/1.3.x.backwards.excludes/java-duration-support-javadsl.excludes
@@ -27,3 +27,4 @@
ProblemFilters.exclude[ReversedMissingMethodProblem]("org.apache.pekko.http.java
ProblemFilters.exclude[ReversedMissingMethodProblem]("org.apache.pekko.http.javadsl.settings.ConnectionPoolSettings.withIdleTimeout")
ProblemFilters.exclude[ReversedMissingMethodProblem]("org.apache.pekko.http.javadsl.settings.ConnectionPoolSettings.withKeepAliveTimeout")
ProblemFilters.exclude[ReversedMissingMethodProblem]("org.apache.pekko.http.javadsl.settings.ConnectionPoolSettings.withMaxConnectionLifetime")
+ProblemFilters.exclude[ReversedMissingMethodProblem]("org.apache.pekko.http.javadsl.settings.ConnectionPoolSettings.withResponseEntitySubscriptionTimeout")
diff --git
a/http-core/src/main/scala/org/apache/pekko/http/impl/settings/ConnectionPoolSettingsImpl.scala
b/http-core/src/main/scala/org/apache/pekko/http/impl/settings/ConnectionPoolSettingsImpl.scala
index cf24a3bde..8c8913875 100644
---
a/http-core/src/main/scala/org/apache/pekko/http/impl/settings/ConnectionPoolSettingsImpl.scala
+++
b/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,
diff --git
a/http-core/src/main/scala/org/apache/pekko/http/javadsl/settings/ConnectionPoolSettings.scala
b/http-core/src/main/scala/org/apache/pekko/http/javadsl/settings/ConnectionPoolSettings.scala
index 2aa7a8c8a..e29f35b27 100644
---
a/http-core/src/main/scala/org/apache/pekko/http/javadsl/settings/ConnectionPoolSettings.scala
+++
b/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))
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
