Struct Session 

pub struct Session {
    pub ws: WebSocket,
    /* private fields */
}

Fields

ws: WebSocket

Implementations

impl Session

pub fn clone(&self) -> Self

impl Session

pub fn from_ws(ws: WebSocket) -> Self

pub async fn connect(addr: &str, path: &str) -> Result<Self>

Examples found in repository

examples/client.rs (line 16)

async fn main() -> session_rs::Result<()> {
    let session = Session::connect("127.0.0.1:8080", "/").await?;

    session.start_receiver();

    println!(
        "Hi: {:?}",
        session
            .request::<Data>("Hello from client".to_string())
            .await?
    );

    println!(
        "Invalid data response: {:?}",
        session
            .request::<Data>("invalid_data".to_string())
            .await?
    );

    tokio::time::sleep(tokio::time::Duration::from_millis(1000)).await;

    session.close().await?;
    Ok(())
}

impl Session

pub fn start_receiver(&self)

Examples found in repository

examples/client.rs (line 18)

async fn main() -> session_rs::Result<()> {
    let session = Session::connect("127.0.0.1:8080", "/").await?;

    session.start_receiver();

    println!(
        "Hi: {:?}",
        session
            .request::<Data>("Hello from client".to_string())
            .await?
    );

    println!(
        "Invalid data response: {:?}",
        session
            .request::<Data>("invalid_data".to_string())
            .await?
    );

    tokio::time::sleep(tokio::time::Duration::from_millis(1000)).await;

    session.close().await?;
    Ok(())
}

pub async fn on<M: Method, Fut: Future<Output = Result<M::Response, M::Error>> + Send + 'static>( &self, handler: impl Fn(u32, M::Request) -> Fut + Send + Sync + 'static, )

Examples found in repository

examples/server.rs (lines 21-29)

async fn main() -> session_rs::Result<()> {
    let server = SessionServer::bind("127.0.0.1:8080").await?;

    server
        .session_loop(async |session, _| {
            session
                .on::<Data, _>(async |_, req| {
                    println!("Msg from client: {req}");

                    if req == "invalid_data" {
                        return Err("Invalid data".to_string());
                    }

                    Ok("Hello from server".to_string())
                })
                .await;

            Ok(())
        })
        .await
}

impl Session

pub async fn send<M: Method>(&self, data: &Message<M>) -> Result<()>

pub async fn use_id(&self) -> u32

pub async fn request<M: Method>( &self, req: M::Request, ) -> Result<Result<M::Response, M::Error>>

Examples found in repository

examples/client.rs (line 23)

async fn main() -> session_rs::Result<()> {
    let session = Session::connect("127.0.0.1:8080", "/").await?;

    session.start_receiver();

    println!(
        "Hi: {:?}",
        session
            .request::<Data>("Hello from client".to_string())
            .await?
    );

    println!(
        "Invalid data response: {:?}",
        session
            .request::<Data>("invalid_data".to_string())
            .await?
    );

    tokio::time::sleep(tokio::time::Duration::from_millis(1000)).await;

    session.close().await?;
    Ok(())
}

pub async fn respond(&self, to: u32, val: Value) -> Result<()>

pub async fn respond_error(&self, to: u32, val: Value) -> Result<()>

pub async fn notify<M: Method>(&self, data: M::Request) -> Result<()>

pub async fn close(&self) -> Result<()>

Examples found in repository

examples/client.rs (line 36)

async fn main() -> session_rs::Result<()> {
    let session = Session::connect("127.0.0.1:8080", "/").await?;

    session.start_receiver();

    println!(
        "Hi: {:?}",
        session
            .request::<Data>("Hello from client".to_string())
            .await?
    );

    println!(
        "Invalid data response: {:?}",
        session
            .request::<Data>("invalid_data".to_string())
            .await?
    );

    tokio::time::sleep(tokio::time::Duration::from_millis(1000)).await;

    session.close().await?;
    Ok(())
}