Struct session_types::ChanSelect

pub struct ChanSelect<'c> { /* fields omitted */ }

Heterogeneous selection structure for channels

This builds a structure of channels that we wish to select over. This is structured in a way such that the channels selected over cannot be interacted with (consumed) as long as the borrowing ChanSelect object exists. This is necessary to ensure memory safety.

The type parameter T is a return type, ie we store a value of some type T that is returned in case its associated channels is selected on wait()

Methods

impl<'c> ChanSelect<'c>

pub fn new() -> ChanSelect<'c>

pub fn add_recv<E, P, A: Send>(&mut self, chan: &'c Chan<E, Recv<A, P>>)

Add a channel whose next step is Recv

Once a channel has been added it cannot be interacted with as long as it is borrowed here (by virtue of borrow checking and lifetimes).

pub fn add_offer<E, P, Q>(&mut self, chan: &'c Chan<E, Offer<P, Q>>)

pub fn wait(self) -> usize

Find a Receiver (and hence a Chan) that is ready to receive.

This method consumes the ChanSelect, freeing up the borrowed Receivers to be consumed.

pub fn len(&self) -> usize

How many channels are there in the structure?