Struct RpcServer 

pub struct RpcServer {
    pub listener: TcpListener,
    pub auth: Arc<Auth>,
    pub handler: Arc<Handler>,
    pub max_connections: usize,
    pub idle_timeout: Duration,
}

Synchronous HTTP/1.1 JSON-RPC server.

Fields

listener: TcpListener

Bound TCP listener.

auth: Arc<Auth>

Shared authentication policy.

handler: Arc<Handler>

Shared JSON-RPC handler.

max_connections: usize

Maximum concurrent worker connections.

idle_timeout: Duration

Idle read timeout for each connection.

Implementations

impl RpcServer

pub fn bind<A: ToSocketAddrs>( address: A, auth: Arc<Auth>, handler: Arc<Handler>, max_connections: usize, idle_timeout: Duration, ) -> Result<Self>

Binds a new RPC server.

pub fn local_addr(&self) -> Result<SocketAddr>

Returns the local socket address.

pub fn serve(self) -> Result<()>

Runs the accept loop. Each accepted connection is handled by one bounded worker thread.

pub fn serve_with_shutdown(self, shutdown: Arc<AtomicBool>) -> Result<()>

Runs the accept loop until shutdown is set to true.

Polls non-blocking accept on a fixed cadence so the loop can observe shutdown without parking on an open socket. Each accepted connection is restored to blocking mode and handed to a bounded worker thread, preserving the configured idle_timeout per connection.