Struct TestingWrapper 

pub struct TestingWrapper<S: AppState> { /* private fields */ }

A testing wrapper around the Client that provides comprehensive statistics and monitoring capabilities for WebSocket connections.

Implementations

impl<S: AppState> TestingWrapper<S>

pub fn new( client: Client<S>, runner: ClientRunner<S>, config: TestingConfig, ) -> Self

Create a new testing wrapper with the provided client and runner

pub fn new_with_stats( client: Client<S>, runner: ClientRunner<S>, config: TestingConfig, stats: Arc<StatisticsTracker>, ) -> Self

Create a new testing wrapper with a shared StatisticsTracker This is useful when you want to share statistics between multiple components

pub fn create_middleware(&self) -> TestingMiddleware<S>

Create a TestingMiddleware that shares the same StatisticsTracker

pub async fn start(&mut self) -> CoreResult<()>

Start the testing wrapper, which will run the client and begin collecting statistics

Examples found in repository

examples/testing_echo_client.rs (line 155)

    pub async fn start(&mut self) -> CoreResult<()> {
        self.testing_wrapper.start().await
    }

pub async fn stop(self) -> CoreResult<ConnectionStats>

Stop the testing wrapper

Examples found in repository

examples/testing_echo_client.rs (line 159)

    pub async fn stop(self) -> CoreResult<()> {
        self.testing_wrapper.stop().await?;
        Ok(())
    }

pub async fn get_stats(&self) -> ConnectionStats

Get the current connection statistics

Examples found in repository

examples/testing_echo_client.rs (line 176)

    pub async fn get_stats(&self) -> binary_options_tools_core_pre::statistics::ConnectionStats {
        self.testing_wrapper.get_stats().await
    }

pub fn client(&self) -> &Client<S>

Get a reference to the underlying client

Examples found in repository

examples/testing_echo_client.rs (line 166)

    pub async fn echo(&self, msg: String) -> CoreResult<String> {
        match self
            .testing_wrapper
            .client()
            .get_handle::<EchoModule>()
            .await
        {
            Some(echo_handle) => echo_handle.echo(msg).await,
            None => Err(CoreError::ModuleNotFound("EchoModule".to_string())),
        }
    }

pub fn client_mut(&mut self) -> &mut Client<S>

Get a mutable reference to the underlying client

pub async fn reset_stats(&self)

Reset all statistics

pub async fn export_stats_json(&self) -> CoreResult<String>

Export statistics to JSON

Examples found in repository

examples/testing_echo_client.rs (line 180)

    pub async fn export_stats_json(&self) -> CoreResult<String> {
        self.testing_wrapper.export_stats_json().await
    }

pub async fn export_stats_csv(&self) -> CoreResult<String>

Export statistics to CSV

Examples found in repository

examples/testing_echo_client.rs (line 184)

    pub async fn export_stats_csv(&self) -> CoreResult<String> {
        self.testing_wrapper.export_stats_csv().await
    }