Struct QuicServer 

pub struct QuicServer { /* private fields */ }

A QUIC server that delegates incoming gRPC requests to a tonic service.

QuicServer
  └── quinn::Endpoint  (accepts QUIC connections)
        └── per connection: accept bi-streams
              └── each bi-stream: read path + gRPC bytes → tonic handler

// Build and start the server:
let server = QuicServer::builder()
    .tls(tls_config)
    .build();

// Pass any tonic-generated Router or service_fn:
server.serve(addr, MyServiceServer::new(my_service)).await?;

Implementations

impl QuicServer

pub fn builder() -> QuicServerBuilder

Return a builder to configure the server.

pub async fn serve<S>( self, addr: SocketAddr, service: S, ) -> Result<(), ServerError>

where S: Service<Request<BoxBody>, Response = Response<BoxBody>> + Clone + Send + Sync + 'static, S::Future: Send + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send,

Bind to addr and serve requests until a shutdown signal is received.

pub async fn serve_with_shutdown<S, F>( self, addr: SocketAddr, service: S, signal: F, ) -> Result<(), ServerError>

where S: Service<Request<BoxBody>, Response = Response<BoxBody>> + Clone + Send + Sync + 'static, S::Future: Send + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send, F: Future<Output = ()> + Send + 'static,

Bind to addr and serve requests until the signal future completes.

pub async fn serve_with_incoming<S>( self, endpoint: QuicEndpoint, service: S, ) -> Result<(), ServerError>

where S: Service<Request<BoxBody>, Response = Response<BoxBody>> + Clone + Send + Sync + 'static, S::Future: Send + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send,

Serve requests over an already-bound QuicEndpoint.

pub async fn serve_with_incoming_shutdown<S, F>( self, endpoint: QuicEndpoint, service: S, signal: F, ) -> Result<(), ServerError>

where S: Service<Request<BoxBody>, Response = Response<BoxBody>> + Clone + Send + Sync + 'static, S::Future: Send + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send, F: Future<Output = ()> + Send + 'static,

Serve requests over an already-bound QuicEndpoint until the signal future completes.

Trait Implementations

impl Debug for QuicServer

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

Formats the value using the given formatter.