Struct async_std_utp::UtpListener [−][src]
pub struct UtpListener { /* fields omitted */ }
Expand description
A structure representing a socket server.
Examples
use async_std_utp::{UtpListener, UtpSocket}; use async_std::{prelude::*, task}; async fn handle_client(socket: UtpSocket) { // ... } // Create a listener let addr = "127.0.0.1:8080"; let listener = UtpListener::bind(addr).await.expect("Error binding socket"); let mut incoming = listener.incoming(); while let Some(connection) = incoming.next().await { // Spawn a new handler for each new connection if let Ok((socket, _src)) = connection { task::spawn(async move { handle_client(socket) }); } }
Implementations
impl UtpListener
[src]
impl UtpListener
[src]pub async fn bind<A: ToSocketAddrs>(addr: A) -> Result<UtpListener>
[src]
pub async fn bind<A: ToSocketAddrs>(addr: A) -> Result<UtpListener>
[src]Creates a new UtpListener
bound to a specific address.
The resulting listener is ready for accepting connections.
The address type can be any implementer of the ToSocketAddr
trait. See its documentation
for concrete examples.
If more than one valid address is specified, only the first will be used.
pub async fn accept(&self) -> Result<(UtpSocket, SocketAddr)>
[src]
pub async fn accept(&self) -> Result<(UtpSocket, SocketAddr)>
[src]Accepts a new incoming connection from this listener.
This function will block the caller until a new uTP connection is established. When
established, the corresponding UtpSocket
and the peer’s remote address will be returned.
Notice that the resulting UtpSocket
is bound to a different local port than the public
listening port (which UtpListener
holds). This may confuse the remote peer!
pub fn incoming(&self) -> Incoming<'_>
[src]
pub fn incoming(&self) -> Incoming<'_>
[src]Returns an iterator over the connections being received by this listener.
The returned iterator will never return None
.
pub fn local_addr(&self) -> Result<SocketAddr>
[src]
pub fn local_addr(&self) -> Result<SocketAddr>
[src]Returns the local socket address of this listener.
Auto Trait Implementations
impl RefUnwindSafe for UtpListener
impl Send for UtpListener
impl Sync for UtpListener
impl Unpin for UtpListener
impl UnwindSafe for UtpListener
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,