Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-13 20:06:30 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix clippy::redundant-async-block warnings

Browse Source
This commit is contained in:
link2xt
2023-03-17 09:20:34 +00:00
parent f024909611
commit edcc199461
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/contact.rs
View File

@@ -1552,7 +1552,7 @@ impl RecentlySeenLoop {
pub(crate) fn new(context: Context) -> Self { pub(crate) fn new(context: Context) -> Self {
let (interrupt_send, interrupt_recv) = channel::bounded(1); let (interrupt_send, interrupt_recv) = channel::bounded(1);
let handle = task::spawn(async move { Self::run(context, interrupt_recv).await }); let handle = task::spawn(Self::run(context, interrupt_recv));
Self { Self {
handle, handle,
interrupt_send, interrupt_send,

8
src/scheduler.rs
View File

@@ -501,7 +501,7 @@ impl Scheduler {
let (inbox_start_send, inbox_start_recv) = channel::bounded(1); let (inbox_start_send, inbox_start_recv) = channel::bounded(1);
let handle = { let handle = {
let ctx = ctx.clone(); let ctx = ctx.clone();
task::spawn(async move { inbox_loop(ctx, inbox_start_send, inbox_handlers).await }) task::spawn(inbox_loop(ctx, inbox_start_send, inbox_handlers))
}; };
let inbox = SchedBox { let inbox = SchedBox {
meaning: FolderMeaning::Inbox, meaning: FolderMeaning::Inbox,
@@ -521,9 +521,7 @@ impl Scheduler {
let (conn_state, handlers) = ImapConnectionState::new(&ctx).await?; let (conn_state, handlers) = ImapConnectionState::new(&ctx).await?;
let (start_send, start_recv) = channel::bounded(1); let (start_send, start_recv) = channel::bounded(1);
let ctx = ctx.clone(); let ctx = ctx.clone();
let handle = task::spawn(async move { let handle = task::spawn(simple_imap_loop(ctx, start_send, handlers, meaning));
simple_imap_loop(ctx, start_send, handlers, meaning).await
});
oboxes.push(SchedBox { oboxes.push(SchedBox {
meaning, meaning,
conn_state, conn_state,
@@ -535,7 +533,7 @@ impl Scheduler {
let smtp_handle = { let smtp_handle = {
let ctx = ctx.clone(); let ctx = ctx.clone();
task::spawn(async move { smtp_loop(ctx, smtp_start_send, smtp_handlers).await }) task::spawn(smtp_loop(ctx, smtp_start_send, smtp_handlers))
}; };
start_recvs.push(smtp_start_recv); start_recvs.push(smtp_start_recv);