Struct ReqResConfig 

pub struct ReqResConfig {
    pub message_timeout: Duration,
    pub max_concurrent_streams: usize,
}

The configuration for a Behaviour protocol.

Fields

message_timeout: Duration

message timeout

max_concurrent_streams: usize

max concurrent streams

Implementations

impl ReqResConfig

pub const fn new( message_timeout: Duration, max_concurrent_streams: usize, ) -> Self

Create a ReqRes Confing

impl ReqResConfig

pub const fn with_message_timeout(self, timeout: Duration) -> Self

Sets the timeout for inbound and outbound requests.

pub const fn with_max_concurrent_streams(self, num_streams: usize) -> Self

Sets the upper bound for the number of concurrent inbound + outbound streams.

pub const fn get_message_timeout(&self) -> Duration

Get message timeout

pub const fn get_max_concurrent_streams(&self) -> usize

Get max concurrent streams

Trait Implementations

impl Clone for ReqResConfig

fn clone(&self) -> ReqResConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReqResConfig

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

Formats the value using the given formatter.

impl Default for ReqResConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ReqResConfig

where ReqResConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.