fn spawn_channel(
        capacity: usize,
    ) -> (
        Sender<ObjectRef<Pod>>,
        task::Spawn<Receiver<ObjectRef<Pod>>>,
    ) {
        let (tx, rx) = channel::<ObjectRef<Pod>>(capacity);
        (tx, task::spawn(rx))
    }
// Spawns a task that reads from the receiver and publishes updates on another mpsc. This is all
// done so that we can use `[task::Spawn`] on a stream type.
Spawns a task that reads from the receiver and publishes updates on another mpsc. This is all
done so that we can use `[task::Spawn`] on a stream type.
Spawns a task that reads from the receiver and publishes updates on another mpsc . This is all done so that we can use ` [ task :: Spawn ` ] on a stream type .
fn spawn_channel(
        capacity: usize,
    ) -> (
        Sender<ObjectRef<Pod>>,
        task::Spawn<Receiver<ObjectRef<Pod>>>,
    ) {
        let (tx, rx) = channel::<ObjectRef<Pod>>(capacity);
        (tx, task::spawn(rx))
    }
fn spawn_channel ( capacity : usize , ) -> ( Sender < ObjectRef < Pod > > , task :: Spawn < Receiver < ObjectRef < Pod > > > , ) { let ( tx , rx ) = channel :: < ObjectRef < Pod > > ( capacity ) ; ( tx , task :: spawn ( rx ) ) }
Spawns a task that reads from the receiver and publishes updates on another mpsc.
Spawns a task that reads from the receiver and publishes updates on another mpsc .
capacity
usize
capacity
usize