Trait xstack_circuit::CircuitV2Rpc

source · 
pub trait CircuitV2Rpc:
    AsyncRead
    + AsyncWrite
    + Unpin {
    // Provided methods
    fn circuit_v2_hop_reserve(
        self,
        max_recv_len: usize,
    ) -> impl Future<Output = Result<Reservation>>
       where Self: Sized { ... }
    fn circuit_v2_hop_connect(
        self,
        id: &PeerId,
        max_recv_len: usize,
    ) -> impl Future<Output = Result<Option<Limit>>>
       where Self: Sized { ... }
    fn circuit_v2_stop_connect(
        self,
        id: PeerId,
        max_recv_len: usize,
    ) -> impl Future<Output = Result<()>>
       where Self: Sized { ... }
    fn circuit_v2_stop_connect_accept(
        self,
        max_recv_len: usize,
    ) -> impl Future<Output = Result<Option<Limit>>>
       where Self: Sized { ... }
}
Expand description

An extension trait for circuit v2 protocol.

Provided Methods§

source

fn circuit_v2_hop_reserve( self, max_recv_len: usize, ) -> impl Future<Output = Result<Reservation>>
where Self: Sized,

make a reservation to relayer via this stream.

source

fn circuit_v2_hop_connect( self, id: &PeerId, max_recv_len: usize, ) -> impl Future<Output = Result<Option<Limit>>>
where Self: Sized,

make a connect to relayer via this stream.

source

fn circuit_v2_stop_connect( self, id: PeerId, max_recv_len: usize, ) -> impl Future<Output = Result<()>>
where Self: Sized,

make a connect to terminator via this stream.

source

fn circuit_v2_stop_connect_accept( self, max_recv_len: usize, ) -> impl Future<Output = Result<Option<Limit>>>
where Self: Sized,

make a connect to relayer via this stream.

Implementors§

source§

impl<S> CircuitV2Rpc for S
where S: AsyncRead + AsyncWrite + Unpin,