Struct SgListen 

pub struct SgListen {
    pub socket_addr: SocketAddr,
    pub services: Vec<Arc<dyn TcpService>>,
    pub listener_id: String,
    /* private fields */
}

Listener embodies the concept of a logical endpoint where a Gateway accepts network connections.

Fields

socket_addr: SocketAddr

services: Vec<Arc<dyn TcpService>>

listener_id: String

Implementations

impl SgListen

pub fn new(socket_addr: SocketAddr, cancel_token: CancellationToken) -> Self

we only have 65535 ports for a console, so it’s a safe size

pub fn with_service<S: TcpService>(self, service: S) -> Self

pub fn add_service<S: TcpService>(&mut self, service: S)

pub fn with_services(self, services: Vec<Arc<dyn TcpService>>) -> Self

pub fn extend_services(&mut self, services: Vec<Arc<dyn TcpService>>)

pub fn with_listener_id(self, listener_id: impl Into<String>) -> Self

impl SgListen

pub fn spawn(self) -> JoinHandle<Result<(), BoxError>>

Spawn the listener on the tokio runtime.

It’s a shortcut for tokio::spawn(listener.listen()).

pub async fn listen(self) -> Result<(), BoxError>

Listen on the socket address.

Trait Implementations

impl Clone for SgListen

fn clone(&self) -> SgListen

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SgListen

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.