Struct DataChannel 

pub struct DataChannel {
    pub id: u32,
    pub closed: AtomicBool,
    pub data_tx: Sender<Data>,
    pub capacity: AtomicU32,
    pub notify: Notify,
}

Fields

id: u32

closed: AtomicBool

data_tx: Sender<Data>

capacity: AtomicU32

notify: Notify

Implementations

impl DataChannel

pub fn new_client(id: u32, data_tx: Sender<Data>) -> DataChannel

pub fn add_capacity(&self, amount: u32)

pub async fn wait_for_capacity( &self, required: u32, ) -> Result<(), SendError<()>>

pub fn close(&self)

pub async fn closed(&self)

Trait Implementations

impl Debug for DataChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.