Struct asyncio::StreamSocket
[−]
[src]
pub struct StreamSocket<P> { /* fields omitted */ }Provides a stream-oriented socket.
pub struct StreamSocket<P> { /* fields omitted */ }Provides a stream-oriented socket.
impl<P: Protocol> StreamSocket<P>[src]fn new(ctx: &IoContext, pro: P) -> Result<StreamSocket<P>>fn async_connect<F>(&self, ep: &P::Endpoint, handler: F) -> F::Output where F: Handler<(), Error>fn async_receive<F>(&self, buf: &mut [u8], flags: i32, handler: F) -> F::Output where F: Handler<usize, Error>fn async_send<F>(&self, buf: &[u8], flags: i32, handler: F) -> F::Output where F: Handler<usize, Error>fn available(&self) -> Result<usize>fn bind(&self, ep: &P::Endpoint) -> Result<()>fn cancel(&self)fn connect(&self, ep: &P::Endpoint) -> Result<()>fn get_non_blocking(&self) -> Result<bool>fn get_option<C>(&self) -> Result<C> where C: GetSocketOption<P>fn io_control<C>(&self, cmd: &mut C) -> Result<()> where C: IoControlfn local_endpoint(&self) -> Result<P::Endpoint>fn receive(&self, buf: &mut [u8], flags: i32) -> Result<usize>fn remote_endpoint(&self) -> Result<P::Endpoint>fn send(&self, buf: &[u8], flags: i32) -> Result<usize>fn set_non_blocking(&self, on: bool) -> Result<()>fn set_option<C>(&self, cmd: C) -> Result<()> where C: SetSocketOption<P>fn shutdown(&self, how: Shutdown) -> Result<()>impl<P: Protocol> Stream<Error> for StreamSocket<P>[src]fn async_read_some<F>(&self, buf: &mut [u8], handler: F) -> F::Output where F: Handler<usize, Error>fn async_write_some<F>(&self, buf: &[u8], handler: F) -> F::Output where F: Handler<usize, Error>fn read_some(&self, buf: &mut [u8]) -> Result<usize>fn write_some(&self, buf: &[u8]) -> Result<usize>impl<P: Protocol> Debug for StreamSocket<P>[src]impl<P> AsRawFd for StreamSocket<P>[src]impl<P> Send for StreamSocket<P>[src]impl<P> AsIoContext for StreamSocket<P>[src]impl<P: Protocol> Socket<P> for StreamSocket<P>[src]unsafe fn from_raw_fd(ctx: &IoContext, pro: P, fd: RawFd) -> StreamSocket<P>fn protocol(&self) -> P