pub struct InFlightService { /* private fields */ }
Expand description
Service that can limit number of in-flight async requests.
Default is 16 in-flight messages and 64kb size
Implementations§
source§impl InFlightService
impl InFlightService
sourcepub fn new(max_receive: u16, max_receive_size: usize) -> Self
pub fn new(max_receive: u16, max_receive_size: usize) -> Self
Create new InFlightService
middleware
By default max receive is 16 and max size is 64kb
sourcepub fn max_receive(self, val: u16) -> Self
pub fn max_receive(self, val: u16) -> Self
Number of inbound in-flight concurrent messages.
By default max receive number is set to 16 messages
sourcepub fn max_receive_size(self, val: usize) -> Self
pub fn max_receive_size(self, val: usize) -> Self
Total size of inbound in-flight messages.
By default total inbound in-flight size is set to 64Kb
Trait Implementations§
source§impl Default for InFlightService
impl Default for InFlightService
Auto Trait Implementations§
impl Freeze for InFlightService
impl RefUnwindSafe for InFlightService
impl Send for InFlightService
impl Sync for InFlightService
impl Unpin for InFlightService
impl UnwindSafe for InFlightService
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