diff options
| author | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-11-02 12:58:45 +0100 |
|---|---|---|
| committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-11-02 12:58:45 +0100 |
| commit | 1e192f93d5bf544c82fe91fb799d77e8b5d53afe (patch) | |
| tree | c069a436429cdea4ada253e6187b2b26aa2852e0 /src/mail/incoming.rs | |
| parent | 3b363b2a7803564231e001c215ab427c99c9435b (diff) | |
| download | aerogramme-1e192f93d5bf544c82fe91fb799d77e8b5d53afe.tar.gz aerogramme-1e192f93d5bf544c82fe91fb799d77e8b5d53afe.zip | |
make all our objects send+sync
Diffstat (limited to 'src/mail/incoming.rs')
| -rw-r--r-- | src/mail/incoming.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mail/incoming.rs b/src/mail/incoming.rs index b7d2f48..3ea7d6a 100644 --- a/src/mail/incoming.rs +++ b/src/mail/incoming.rs @@ -54,10 +54,10 @@ async fn incoming_mail_watch_process_internal( creds: Credentials, mut rx_inbox_id: watch::Receiver<Option<(UniqueIdent, ImapUidvalidity)>>, ) -> Result<()> { - let mut lock_held = k2v_lock_loop(creds.k2v_client()?, INCOMING_PK, INCOMING_LOCK_SK); + let mut lock_held = k2v_lock_loop(creds.row_client()?, INCOMING_PK, INCOMING_LOCK_SK); - let k2v = creds.k2v_client()?; - let s3 = creds.s3_client()?; + let k2v = creds.row_client()?; + let s3 = creds.blob_client()?; let mut inbox: Option<Arc<Mailbox>> = None; let mut prev_ct: Option<CausalityToken> = None; |