impl Send/Senc for Queue (#483)

avsaase · web-flow · commit 6cbf8b9da464 · 2024-03-19T08:45:25.000-04:00
diff --git a/worker/src/queue.rs b/worker/src/queue.rs
@@ -145,6 +145,9 @@ impl<'a, T> std::iter::ExactSizeIterator for MessageIter<'a, T> where T: Deseria
 
 pub struct Queue(EdgeQueue);
 
+unsafe impl Send for Queue {}
+unsafe impl Sync for Queue {}
+
 impl EnvBinding for Queue {
     const TYPE_NAME: &'static str = "WorkerQueue";
 }

Original file line number	Diff line number	Diff line change
`@@ -145,6 +145,9 @@ impl<'a, T> std::iter::ExactSizeIterator for MessageIter<'a, T> where T: Deseria`
`145`	`145`
`146`	`146`	`pub struct Queue(EdgeQueue);`
`147`	`147`
	`148`	`+unsafe impl Send for Queue {}`
	`149`	`+unsafe impl Sync for Queue {}`
	`150`	`+`
`148`	`151`	`impl EnvBinding for Queue {`
`149`	`152`	`const TYPE_NAME: &'static str = "WorkerQueue";`
`150`	`153`	`}`