Struct krpc::stream::Stream
[−]
[src]
pub struct Stream { /* fields omitted */ }Methods
impl Stream[src]
fn new<T: ToSocketAddrs>(address: T, rpc: Rpc) -> Result<Self, ConnectionErr>
fn add_stream(
&mut self,
service: String,
procedure: String,
args: Vec<Vec<u8>>
) -> Result<u32, TransceiverError>
&mut self,
service: String,
procedure: String,
args: Vec<Vec<u8>>
) -> Result<u32, TransceiverError>
fn remove_stream(&mut self, id: u32) -> Result<(), TransceiverError>
fn receive(
&mut self
) -> Result<BTreeMap<u32, Option<Vec<u8>>>, TransceiverError>
&mut self
) -> Result<BTreeMap<u32, Option<Vec<u8>>>, TransceiverError>