Skip to content
This repository was archived by the owner on Jan 4, 2026. It is now read-only.

Commit d48d861

Browse files
committed
Send impls
1 parent c631232 commit d48d861

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

src/prod_cons/stream.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,8 @@ where
104104
}
105105
}
106106

107+
unsafe impl<Q: BbqHandle + Send> Send for StreamProducer<Q> {}
108+
107109
pub struct StreamConsumer<Q>
108110
where
109111
Q: BbqHandle,
@@ -141,6 +143,8 @@ where
141143
}
142144
}
143145

146+
unsafe impl<Q: BbqHandle + Send> Send for StreamConsumer<Q> {}
147+
144148
pub struct StreamGrantW<Q>
145149
where
146150
Q: BbqHandle,
@@ -171,6 +175,8 @@ where
171175
}
172176
}
173177

178+
unsafe impl<Q: BbqHandle + Send> Send for StreamGrantW<Q> {}
179+
174180
impl<Q> Drop for StreamGrantW<Q>
175181
where
176182
Q: BbqHandle,
@@ -237,6 +243,8 @@ where
237243
}
238244
}
239245

246+
unsafe impl<Q: BbqHandle + Send> Send for StreamGrantR<Q> {}
247+
240248
impl<Q> Drop for StreamGrantR<Q>
241249
where
242250
Q: BbqHandle,

0 commit comments

Comments
 (0)