make PgCopyBoth cloneable (it's all Arc under the hood)

grim7reaper · grim7reaper · commit d104e2ec7660 · 2024-01-05T16:29:11.000+01:00
Also remove an unecessary mut
diff --git a/sqlx-postgres/src/copy.rs b/sqlx-postgres/src/copy.rs
@@ -373,6 +373,7 @@ enum PgCopyBothCommand {
     CopyDone { from_client: bool },
 }
 
+#[derive(Clone)]
 pub struct PgCopyBoth {
     recv_stream: flume::r#async::RecvStream<'static, Result<Bytes>>,
     send_tx: flume::Sender<PgCopyBothCommand>,
@@ -441,7 +442,7 @@ impl PgCopyBoth {
     }
 
     /// Send a chunk of `COPY` data.
-    pub async fn send(&mut self, data: impl Into<Vec<u8>>) -> Result<()> {
+    pub async fn send(&self, data: impl Into<Vec<u8>>) -> Result<()> {
         self.send_tx
             .send_async(PgCopyBothCommand::CopyData(data.into()))
             .await

Original file line number	Diff line number	Diff line change
`@@ -373,6 +373,7 @@ enum PgCopyBothCommand {`
`373`	`373`	`CopyDone { from_client: bool },`
`374`	`374`	`}`
`375`	`375`
	`376`	`+#[derive(Clone)]`
`376`	`377`	`pub struct PgCopyBoth {`
`377`	`378`	`recv_stream: flume::r#async::RecvStream<'static, Result<Bytes>>,`
`378`	`379`	`send_tx: flume::Sender<PgCopyBothCommand>,`
`@@ -441,7 +442,7 @@ impl PgCopyBoth {`
`441`	`442`	`}`
`442`	`443`
`443`	`444`	/// Send a chunk of `COPY` data.
`444`		`- pub async fn send(&mut self, data: impl Into<Vec<u8>>) -> Result<()> {`
	`445`	`+ pub async fn send(&self, data: impl Into<Vec<u8>>) -> Result<()> {`
`445`	`446`	`self.send_tx`
`446`	`447`	`.send_async(PgCopyBothCommand::CopyData(data.into()))`
`447`	`448`	`.await`