Struct kinetic::channel::AsyncChannel [−] [src]

pub struct AsyncChannel {
    // some fields omitted
}

Methods

`impl AsyncChannel`

`fn new<A: ToSocketAddrs>(addr: A, max_pending: usize) -> KineticResult<AsyncChannel>`

Trait Implementations

`impl Drop for AsyncChannel`

`fn drop(&mut self)`

`impl KineticChannel<Receiver<Result>> for AsyncChannel`

`fn is_closed(&self) -> bool`

`fn get_unsolicited_receiver<'r>(&'r self) -> &'r Receiver<Result>`

`fn get_configuration<'r>(&'r self) -> &'r Configuration`

`fn get_limits<'r>(&'r self) -> &'r Limits`

`fn send(&self, op: Operation) -> Receiver<Result>`

`fn receive(rx: Receiver<Result>) -> Result`