diff options
author | Quentin Dufour <quentin@deuxfleurs.fr> | 2022-06-28 10:49:28 +0200 |
---|---|---|
committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2022-06-28 10:49:28 +0200 |
commit | 36bbc2138bceb0c80a306f8c225e340d6fbd5470 (patch) | |
tree | 9592daf96a58a61b16337968b662e85199e0e158 /src/imap/session.rs | |
parent | 927b461f25e8202a33fadc1f823d4feed6282f60 (diff) | |
download | aerogramme-36bbc2138bceb0c80a306f8c225e340d6fbd5470.tar.gz aerogramme-36bbc2138bceb0c80a306f8c225e340d6fbd5470.zip |
cargo fmt + implement noop
Diffstat (limited to 'src/imap/session.rs')
-rw-r--r-- | src/imap/session.rs | 15 |
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 |