pub struct Listener { /* private fields */ }Expand description
High-level listener that accepts inbound RakNet peers as Connection objects.
Implementations§
Source§impl Listener
impl Listener
Sourcepub async fn bind(bind_addr: SocketAddr) -> Result<Self, ServerError>
pub async fn bind(bind_addr: SocketAddr) -> Result<Self, ServerError>
Creates a listener bound to bind_addr with default configs.
Sourcepub fn set_pong_data(&mut self, data: impl Into<String>)
pub fn set_pong_data(&mut self, data: impl Into<String>)
Sets pong/advertisement payload returned during offline ping.
Sourcepub fn set_accept_queue_capacity(&mut self, capacity: usize)
pub fn set_accept_queue_capacity(&mut self, capacity: usize)
Sets incoming connection queue capacity.
Sourcepub fn set_inbound_queue_capacity(&mut self, capacity: usize)
pub fn set_inbound_queue_capacity(&mut self, capacity: usize)
Sets per-connection inbound packet queue capacity.
Sourcepub fn set_command_queue_capacity(&mut self, capacity: usize)
pub fn set_command_queue_capacity(&mut self, capacity: usize)
Sets command channel capacity used by accepted Connections.
Sourcepub fn set_shard_count(&mut self, shard_count: usize)
pub fn set_shard_count(&mut self, shard_count: usize)
Sets shard count (minimum 1).
Sourcepub fn bind_addr(&self) -> SocketAddr
pub fn bind_addr(&self) -> SocketAddr
Returns configured bind address.
Sourcepub fn metadata(&self) -> ListenerMetadata
pub fn metadata(&self) -> ListenerMetadata
Returns listener metadata snapshot.
Sourcepub fn is_started(&self) -> bool
pub fn is_started(&self) -> bool
Returns true if runtime is started.
Sourcepub async fn start(&mut self) -> Result<(), ServerError>
pub async fn start(&mut self) -> Result<(), ServerError>
Starts listener runtime.
Sourcepub async fn stop(&mut self) -> Result<(), ServerError>
pub async fn stop(&mut self) -> Result<(), ServerError>
Stops listener runtime and disconnects active peers.
Sourcepub async fn accept(&mut self) -> Result<Connection, ServerError>
pub async fn accept(&mut self) -> Result<Connection, ServerError>
Accepts next inbound connection.
Sourcepub fn incoming(&mut self) -> Result<Incoming<'_>, ServerError>
pub fn incoming(&mut self) -> Result<Incoming<'_>, ServerError>
Returns Incoming helper for stream-style accept loop.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Listener
impl RefUnwindSafe for Listener
impl Send for Listener
impl Sync for Listener
impl Unpin for Listener
impl UnsafeUnpin for Listener
impl UnwindSafe for Listener
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more