pebble/rendering/
sync.rs

1/// The sending half of a one-shot backend initialisation channel.
2///
3/// Pass this to [`Backend::init`](crate::rendering::backend::Backend::init) so
4/// the (potentially async) init task can deliver the finished backend.
5pub struct InitSender<T>(oneshot::Sender<T>);
6
7impl<T: 'static + Send> InitSender<T> {
8    /// Send the completed backend to the waiting receiver.
9    ///
10    /// Logs a warning if the receiver was already dropped.
11    pub fn send(self, value: T) {
12        if self.0.send(value).is_err() {
13            tracing::warn!("GPU Backend finished init but receiver was dropped");
14        }
15    }
16}
17
18/// The receiving half of a one-shot backend initialisation channel.
19pub struct InitReceiver<T>(oneshot::Receiver<T>);
20
21impl<T: 'static + Send> InitReceiver<T> {
22    /// Non-blocking poll for the completed backend.
23    pub fn try_recv(&mut self) -> Result<T, oneshot::TryRecvError> {
24        self.0.try_recv()
25    }
26}
27
28/// Create a matched [`InitSender`] / [`InitReceiver`] pair for communicating a
29/// finished backend from its init task back to the main loop.
30pub fn init_channel<T: 'static + Send>() -> (InitSender<T>, InitReceiver<T>) {
31    let (tx, rx) = oneshot::channel();
32    (InitSender(tx), InitReceiver(rx))
33}
pebble/rendering/sync.rs

pebble/rendering/
sync.rs
