pub struct Config { /* private fields */ }
Expand description
The yamux configuration.
Implementations§
source§impl Config
impl Config
sourcepub fn client() -> Config
pub fn client() -> Config
Creates a new YamuxConfig
in client mode, regardless of whether
it will be used for an inbound or outbound upgrade.
sourcepub fn server() -> Config
pub fn server() -> Config
Creates a new YamuxConfig
in server mode, regardless of whether
it will be used for an inbound or outbound upgrade.
sourcepub fn set_receive_window_size(&mut self, num_bytes: u32) -> &mut Config
pub fn set_receive_window_size(&mut self, num_bytes: u32) -> &mut Config
Sets the size (in bytes) of the receive window per substream.
sourcepub fn set_max_buffer_size(&mut self, num_bytes: usize) -> &mut Config
pub fn set_max_buffer_size(&mut self, num_bytes: usize) -> &mut Config
Sets the maximum size (in bytes) of the receive buffer per substream.
sourcepub fn set_max_num_streams(&mut self, num_streams: usize) -> &mut Config
pub fn set_max_num_streams(&mut self, num_streams: usize) -> &mut Config
Sets the maximum number of concurrent substreams.
sourcepub fn set_window_update_mode(&mut self, mode: WindowUpdateMode) -> &mut Config
pub fn set_window_update_mode(&mut self, mode: WindowUpdateMode) -> &mut Config
Sets the window update mode that determines when the remote is given new credit for sending more data.
Trait Implementations§
source§impl<C> InboundUpgrade<C> for Config
impl<C> InboundUpgrade<C> for Config
§type Output = Muxer<C>
type Output = Muxer<C>
Output after the upgrade has been successfully negotiated and the handshake performed.
§type Future = Ready<Result<<Config as InboundUpgrade<C>>::Output, <Config as InboundUpgrade<C>>::Error>>
type Future = Ready<Result<<Config as InboundUpgrade<C>>::Output, <Config as InboundUpgrade<C>>::Error>>
Future that performs the handshake with the remote.
source§fn upgrade_inbound(
self,
io: C,
_: <Config as UpgradeInfo>::Info,
) -> <Config as InboundUpgrade<C>>::Future
fn upgrade_inbound( self, io: C, _: <Config as UpgradeInfo>::Info, ) -> <Config as InboundUpgrade<C>>::Future
After we have determined that the remote supports one of the protocols we support, this
method is called to start the handshake. Read more
source§impl<C> OutboundUpgrade<C> for Config
impl<C> OutboundUpgrade<C> for Config
§type Output = Muxer<C>
type Output = Muxer<C>
Output after the upgrade has been successfully negotiated and the handshake performed.
§type Future = Ready<Result<<Config as OutboundUpgrade<C>>::Output, <Config as OutboundUpgrade<C>>::Error>>
type Future = Ready<Result<<Config as OutboundUpgrade<C>>::Output, <Config as OutboundUpgrade<C>>::Error>>
Future that performs the handshake with the remote.
source§fn upgrade_outbound(
self,
io: C,
_: <Config as UpgradeInfo>::Info,
) -> <Config as OutboundUpgrade<C>>::Future
fn upgrade_outbound( self, io: C, _: <Config as UpgradeInfo>::Info, ) -> <Config as OutboundUpgrade<C>>::Future
After we have determined that the remote supports one of the protocols we support, this
method is called to start the handshake. Read more
source§impl UpgradeInfo for Config
impl UpgradeInfo for Config
source§fn protocol_info(&self) -> <Config as UpgradeInfo>::InfoIter
fn protocol_info(&self) -> <Config as UpgradeInfo>::InfoIter
Returns the list of protocols that are supported. Used during the negotiation process.
Auto Trait Implementations§
impl Freeze for Config
impl RefUnwindSafe for Config
impl Send for Config
impl Sync for Config
impl Unpin for Config
impl UnwindSafe for Config
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<U, T> InboundConnectionUpgrade<T> for Uwhere
U: InboundUpgrade<T>,
impl<U, T> InboundConnectionUpgrade<T> for Uwhere
U: InboundUpgrade<T>,
§type Output = <U as InboundUpgrade<T>>::Output
type Output = <U as InboundUpgrade<T>>::Output
Output after the upgrade has been successfully negotiated and the handshake performed.
§type Error = <U as InboundUpgrade<T>>::Error
type Error = <U as InboundUpgrade<T>>::Error
Possible error during the handshake.
§type Future = <U as InboundUpgrade<T>>::Future
type Future = <U as InboundUpgrade<T>>::Future
Future that performs the handshake with the remote.
source§fn upgrade_inbound(
self,
socket: T,
info: <U as UpgradeInfo>::Info,
) -> <U as InboundConnectionUpgrade<T>>::Future
fn upgrade_inbound( self, socket: T, info: <U as UpgradeInfo>::Info, ) -> <U as InboundConnectionUpgrade<T>>::Future
After we have determined that the remote supports one of the protocols we support, this
method is called to start the handshake. Read more
source§impl<T, TInfo> InboundUpgradeSend for Twhere
T: InboundUpgrade<Stream, Info = TInfo> + UpgradeInfoSend<Info = TInfo>,
TInfo: AsRef<str> + Clone + Send + 'static,
<T as InboundUpgrade<Stream>>::Output: Send + 'static,
<T as InboundUpgrade<Stream>>::Error: Send + 'static,
<T as InboundUpgrade<Stream>>::Future: Send + 'static,
impl<T, TInfo> InboundUpgradeSend for Twhere
T: InboundUpgrade<Stream, Info = TInfo> + UpgradeInfoSend<Info = TInfo>,
TInfo: AsRef<str> + Clone + Send + 'static,
<T as InboundUpgrade<Stream>>::Output: Send + 'static,
<T as InboundUpgrade<Stream>>::Error: Send + 'static,
<T as InboundUpgrade<Stream>>::Future: Send + 'static,
§type Output = <T as InboundUpgrade<Stream>>::Output
type Output = <T as InboundUpgrade<Stream>>::Output
Equivalent to
InboundUpgrade::Output
.§type Error = <T as InboundUpgrade<Stream>>::Error
type Error = <T as InboundUpgrade<Stream>>::Error
Equivalent to
InboundUpgrade::Error
.§type Future = <T as InboundUpgrade<Stream>>::Future
type Future = <T as InboundUpgrade<Stream>>::Future
Equivalent to
InboundUpgrade::Future
.source§fn upgrade_inbound(
self,
socket: Stream,
info: TInfo,
) -> <T as InboundUpgradeSend>::Future
fn upgrade_inbound( self, socket: Stream, info: TInfo, ) -> <T as InboundUpgradeSend>::Future
Equivalent to
InboundUpgrade::upgrade_inbound
.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<U, T> OutboundConnectionUpgrade<T> for Uwhere
U: OutboundUpgrade<T>,
impl<U, T> OutboundConnectionUpgrade<T> for Uwhere
U: OutboundUpgrade<T>,
§type Output = <U as OutboundUpgrade<T>>::Output
type Output = <U as OutboundUpgrade<T>>::Output
Output after the upgrade has been successfully negotiated and the handshake performed.
§type Error = <U as OutboundUpgrade<T>>::Error
type Error = <U as OutboundUpgrade<T>>::Error
Possible error during the handshake.
§type Future = <U as OutboundUpgrade<T>>::Future
type Future = <U as OutboundUpgrade<T>>::Future
Future that performs the handshake with the remote.
source§fn upgrade_outbound(
self,
socket: T,
info: <U as UpgradeInfo>::Info,
) -> <U as OutboundConnectionUpgrade<T>>::Future
fn upgrade_outbound( self, socket: T, info: <U as UpgradeInfo>::Info, ) -> <U as OutboundConnectionUpgrade<T>>::Future
After we have determined that the remote supports one of the protocols we support, this
method is called to start the handshake. Read more
source§impl<T, TInfo> OutboundUpgradeSend for Twhere
T: OutboundUpgrade<Stream, Info = TInfo> + UpgradeInfoSend<Info = TInfo>,
TInfo: AsRef<str> + Clone + Send + 'static,
<T as OutboundUpgrade<Stream>>::Output: Send + 'static,
<T as OutboundUpgrade<Stream>>::Error: Send + 'static,
<T as OutboundUpgrade<Stream>>::Future: Send + 'static,
impl<T, TInfo> OutboundUpgradeSend for Twhere
T: OutboundUpgrade<Stream, Info = TInfo> + UpgradeInfoSend<Info = TInfo>,
TInfo: AsRef<str> + Clone + Send + 'static,
<T as OutboundUpgrade<Stream>>::Output: Send + 'static,
<T as OutboundUpgrade<Stream>>::Error: Send + 'static,
<T as OutboundUpgrade<Stream>>::Future: Send + 'static,
§type Output = <T as OutboundUpgrade<Stream>>::Output
type Output = <T as OutboundUpgrade<Stream>>::Output
Equivalent to
OutboundUpgrade::Output
.§type Error = <T as OutboundUpgrade<Stream>>::Error
type Error = <T as OutboundUpgrade<Stream>>::Error
Equivalent to
OutboundUpgrade::Error
.§type Future = <T as OutboundUpgrade<Stream>>::Future
type Future = <T as OutboundUpgrade<Stream>>::Future
Equivalent to
OutboundUpgrade::Future
.source§fn upgrade_outbound(
self,
socket: Stream,
info: TInfo,
) -> <T as OutboundUpgradeSend>::Future
fn upgrade_outbound( self, socket: Stream, info: TInfo, ) -> <T as OutboundUpgradeSend>::Future
Equivalent to
OutboundUpgrade::upgrade_outbound
.source§impl<T> UpgradeInfoSend for Twhere
T: UpgradeInfo + Send + 'static,
<T as UpgradeInfo>::Info: Send + 'static,
<<T as UpgradeInfo>::InfoIter as IntoIterator>::IntoIter: Send + 'static,
impl<T> UpgradeInfoSend for Twhere
T: UpgradeInfo + Send + 'static,
<T as UpgradeInfo>::Info: Send + 'static,
<<T as UpgradeInfo>::InfoIter as IntoIterator>::IntoIter: Send + 'static,
§type Info = <T as UpgradeInfo>::Info
type Info = <T as UpgradeInfo>::Info
Equivalent to
UpgradeInfo::Info
.§type InfoIter = <<T as UpgradeInfo>::InfoIter as IntoIterator>::IntoIter
type InfoIter = <<T as UpgradeInfo>::InfoIter as IntoIterator>::IntoIter
Equivalent to
UpgradeInfo::InfoIter
.source§fn protocol_info(&self) -> <T as UpgradeInfoSend>::InfoIter
fn protocol_info(&self) -> <T as UpgradeInfoSend>::InfoIter
Equivalent to
UpgradeInfo::protocol_info
.