Struct s2n_netbench::scenario::builder::stream::Stream

pub struct Stream<Endpoint, Location> { /* private fields */ }

Implementations

impl<Endpoint, Location> Stream<Endpoint, Location>

pub fn send(&mut self, bytes: Byte) -> &mut Self

pub fn set_send_rate(&mut self, rate: Rate) -> &mut Self

pub fn receive(&mut self, bytes: Byte) -> &mut Self

pub fn set_receive_rate(&mut self, rate: Rate) -> &mut Self

pub fn receive_all(&mut self) -> &mut Self

pub fn park( &mut self, checkpoint: Checkpoint<Endpoint, Location, Park> ) -> &mut Self

pub fn unpark( &mut self, checkpoint: Checkpoint<Endpoint, Location, Unpark> ) -> &mut Self

pub fn sleep(&mut self, amount: Duration) -> &mut Self

pub fn trace(&mut self, name: &str) -> &mut Self

pub fn profile<F: FnOnce(&mut Self)>(&mut self, name: &str, f: F) -> &mut Self

pub fn iterate<I: Into<IterateValue>, F: FnOnce(&mut Self)>( &mut self, count: I, f: F ) -> &mut Self

pub fn concurrently<S: FnOnce(&mut SendStream<Endpoint, Location>), R: FnOnce(&mut ReceiveStream<Endpoint, Location>)>( &mut self, send: S, receive: R ) -> &mut Self