This is an automated email from the ASF dual-hosted git repository.
chibenwa pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new 729ed81d65 [FIX] Better handle InterruptedException in
receiveMessageInTimespan (#3083)
729ed81d65 is described below
commit 729ed81d6586ec3966a74be85c62006ed6cdeeea
Author: Benoit TELLIER <[email protected]>
AuthorDate: Tue Jul 7 08:20:35 2026 +0200
[FIX] Better handle InterruptedException in receiveMessageInTimespan (#3083)
---
.../main/scala/org/apache/james/jmap/rfc8621/contract/package.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/server/protocols/jmap-rfc-8621-integration-tests/jmap-rfc-8621-integration-tests-common/src/main/scala/org/apache/james/jmap/rfc8621/contract/package.scala
b/server/protocols/jmap-rfc-8621-integration-tests/jmap-rfc-8621-integration-tests-common/src/main/scala/org/apache/james/jmap/rfc8621/contract/package.scala
index a004d608dc..ca01057081 100644
---
a/server/protocols/jmap-rfc-8621-integration-tests/jmap-rfc-8621-integration-tests-common/src/main/scala/org/apache/james/jmap/rfc8621/contract/package.scala
+++
b/server/protocols/jmap-rfc-8621-integration-tests/jmap-rfc-8621-integration-tests-common/src/main/scala/org/apache/james/jmap/rfc8621/contract/package.scala
@@ -48,7 +48,9 @@ package object contract {
.repeat()
.take(timeout)
.onErrorResume {
- case _: TimeoutException =>
+ // Cancelling the time-bounded take() interrupts the blocking
ws.receive(),
+ // surfacing an InterruptedException that must be swallowed like the
timeout.
+ case _: TimeoutException | _: InterruptedException =>
Flux.empty[String]
}
.collectSeq()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
