Struct JaxProtocol 

pub struct JaxProtocol { /* private fields */ }

Protocol handler for the JAX protocol

Accepts incoming connections and handles ping requests

Implementations

impl JaxProtocol

pub fn new(state: Arc<dyn BucketStateProvider>) -> Self

Create a new JAX protocol handler with the given state provider

pub fn handle_connection( self, conn: Connection, ) -> BoxFuture<'static, Result<(), AcceptError>>

Handle an incoming connection

This is called by the iroh router for each incoming connection with the JAX ALPN.

Trait Implementations

impl Clone for JaxProtocol

fn clone(&self) -> JaxProtocol

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JaxProtocol

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

Formats the value using the given formatter.

impl ProtocolHandler for JaxProtocol

fn accept( &self, conn: Connection, ) -> BoxFuture<'static, Result<(), AcceptError>>

Handle an incoming connection.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.