Struct StreamEchoServer 

pub struct StreamEchoServer<P: StreamProtocol> { /* private fields */ }

Generic stream-based echo server that works with any stream protocol

This server can work with any protocol that implements StreamProtocol, such as TCP, Unix streams, etc.

Examples

Basic server setup and running:

use echosrv::stream::{StreamConfig, StreamEchoServer};
use echosrv::common::EchoServerTrait;
use echosrv::tcp::TcpProtocol;
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = StreamConfig {
        bind_addr: "127.0.0.1:8080".parse()?,
        max_connections: 100,
        buffer_size: 1024,
        read_timeout: Duration::from_secs(30),
        write_timeout: Duration::from_secs(30),
    };

    let server: StreamEchoServer<TcpProtocol> = StreamEchoServer::new(config);
    server.run().await?;
    Ok(())
}

Implementations

impl<P: StreamProtocol> StreamEchoServer<P>

where P::Error: Into<EchoError> + Display,

pub fn new(config: StreamConfig) -> Self

Creates a new stream-based echo server with the given configuration

Trait Implementations

impl<P: StreamProtocol + Sync> EchoServerTrait for StreamEchoServer<P>

where P::Error: Into<EchoError> + Display, P::Stream: 'static,

fn run<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts the stream-based echo server and listens for connections

fn shutdown_signal(&self) -> Sender<()>

Returns a shutdown signal sender that can be used to gracefully shutdown the server