From 1c692d8c32ed16efd626e42a32a5ce295a447714 Mon Sep 17 00:00:00 2001 From: aniketfuryrocks Date: Mon, 6 Mar 2023 20:18:43 +0530 Subject: [PATCH] mut --- src/workers/postgres.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/workers/postgres.rs b/src/workers/postgres.rs index 6b8d5629..840d707d 100644 --- a/src/workers/postgres.rs +++ b/src/workers/postgres.rs @@ -230,7 +230,7 @@ impl Postgres { Ok(self.session.read().await) } - pub fn start(self, mut recv: PostgresMpscRecv) -> JoinHandle> { + pub fn start(mut self, mut recv: PostgresMpscRecv) -> JoinHandle> { tokio::spawn(async move { info!("Writing to postgres");