You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2022/04/19 04:04:39 UTC
[james-project] 48/49: JAMES-3737 Remove unneeded defer
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 99dcf5eaf213558e6fcc54bad649d187f8ffc76f
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Fri Apr 15 23:07:21 2022 +0700
JAMES-3737 Remove unneeded defer
---
.../java/org/apache/james/imap/processor/AbstractMailboxProcessor.java | 2 +-
.../main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/protocols/imap/src/main/java/org/apache/james/imap/processor/AbstractMailboxProcessor.java b/protocols/imap/src/main/java/org/apache/james/imap/processor/AbstractMailboxProcessor.java
index 2683cbec33..ff9aa3d117 100644
--- a/protocols/imap/src/main/java/org/apache/james/imap/processor/AbstractMailboxProcessor.java
+++ b/protocols/imap/src/main/java/org/apache/james/imap/processor/AbstractMailboxProcessor.java
@@ -175,7 +175,7 @@ public abstract class AbstractMailboxProcessor<R extends ImapRequest> extends Ab
selected.resetRecentUidRemoved();
}
})
- .then(Mono.defer(() -> addFlagsResponses(session, selected, responder, useUid)))
+ .then(addFlagsResponses(session, selected, responder, useUid))
.doFinally(type -> selected.resetEvents());
}
diff --git a/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java b/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
index 066a62c475..3abbc9fb90 100644
--- a/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
+++ b/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
@@ -114,7 +114,7 @@ public class FetchProcessor extends AbstractMailboxProcessor<FetchRequest> {
return processMessageRanges(session, mailbox, ranges, fetch, mailboxSession, responder)
// Don't send expunge responses if FETCH is used to trigger this
// processor. See IMAP-284
- .then(Mono.defer(() -> unsolicitedResponses(session, responder, omitExpunged, useUids)))
+ .then(unsolicitedResponses(session, responder, omitExpunged, useUids))
.then(Mono.fromRunnable(() -> okComplete(request, responder)));
}).sneakyThrow())
.doOnEach(logOnError(MessageRangeException.class, e -> LOGGER.debug("Fetch failed for mailbox {} because of invalid sequence-set {}", session.getSelected().getMailboxId(), idSet, e)))
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org