aboutsummaryrefslogtreecommitdiff
path: root/src/imap/session.rs
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2022-06-28 10:49:28 +0200
committerQuentin Dufour <quentin@deuxfleurs.fr>2022-06-28 10:49:28 +0200
commit36bbc2138bceb0c80a306f8c225e340d6fbd5470 (patch)
tree9592daf96a58a61b16337968b662e85199e0e158 /src/imap/session.rs
parent927b461f25e8202a33fadc1f823d4feed6282f60 (diff)
downloadaerogramme-36bbc2138bceb0c80a306f8c225e340d6fbd5470.tar.gz
aerogramme-36bbc2138bceb0c80a306f8c225e340d6fbd5470.zip
cargo fmt + implement noop
Diffstat (limited to 'src/imap/session.rs')
-rw-r--r--src/imap/session.rs15
1 files changed, 6 insertions, 9 deletions
diff --git a/src/imap/session.rs b/src/imap/session.rs
index dfef0f4..d45a989 100644
--- a/src/imap/session.rs
+++ b/src/imap/session.rs
@@ -49,16 +49,10 @@ impl Manager {
match self.tx.try_send(msg) {
Ok(()) => (),
Err(TrySendError::Full(_)) => {
- return async {
- Response::bad("Too fast! Send less pipelined requests.")
- }
- .boxed()
+ return async { Response::bad("Too fast! Send less pipelined requests.") }.boxed()
}
Err(TrySendError::Closed(_)) => {
- return async {
- Response::bad("Session task has existed.")
- }
- .boxed()
+ return async { Response::bad("Session task has existed.") }.boxed()
}
};
@@ -130,8 +124,11 @@ impl Instance {
// Process result
let res = match ctrl {
Ok((res, tr)) => {
- //@FIXME unwrap
+ //@FIXME remove unwrap
self.state = self.state.apply(tr).unwrap();
+
+ //@FIXME enrich here the command with some status
+
Ok(res)
}
// Cast from anyhow::Error to Bal::Error