(james-project) 03/09: [FIX] IDLE execution in the reactive chain

[btellier]

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit d471e81e2fcced3be4124b69b333f9277581c350
Author: Benoit TELLIER <btell...@linagora.com>
AuthorDate: Wed Nov 6 13:16:17 2024 +0100

    [FIX] IDLE execution in the reactive chain
---
 .../main/java/org/apache/james/imap/processor/IdleProcessor.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
 
b/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
index 8ab1d550ae..f83707bb7f 100644
--- 
a/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
+++ 
b/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java
@@ -79,6 +79,11 @@ public class IdleProcessor extends 
AbstractMailboxProcessor<IdleRequest> impleme
 
     @Override
     protected Mono<Void> processRequestReactive(IdleRequest request, 
ImapSession session, Responder responder) {
+        return Mono.fromRunnable(() -> idle(request,session, responder))
+            .then(unsolicitedResponses(session, responder, false));
+    }
+
+    private void idle(IdleRequest request, ImapSession session, Responder 
responder) {
         SelectedMailbox sm = session.getSelected();
         if (sm != null) {
             sm.registerIdle(new IdleMailboxListener(session, responder));
@@ -144,7 +149,6 @@ public class IdleProcessor extends 
AbstractMailboxProcessor<IdleRequest> impleme
         // Write the response after the listener was add
         // IMAP-341
         responder.respond(new ContinuationResponse(HumanReadableText.IDLING));
-        return unsolicitedResponses(session, responder, false);
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org