RSocket Transport For Websocket

Example

Add dependencies in your Cargo.toml.

toml [dependencies] tokio = "0.3.6" rsocket_rust = "0.7.0" rsocket_rust_transport_websocket = "0.7.0"

Server

```rust use log::info; use rsocketrust::prelude::*; use rsocketrust::utils::EchoRSocket; use rsocketrust::Result; use rsocketrusttransportwebsocket::WebsocketServerTransport;

[tokio::main]

async fn main() -> Result<()> { let transport: WebsocketServerTransport = WebsocketServerTransport::from("127.0.0.1:8080");

let responder: ServerResponder = Box::new(|setup, _socket| {
    info!("accept setup: {:?}", setup);
    Ok(Box::new(EchoRSocket))
    // Or you can reject setup
    // Err(From::from("SETUP_NOT_ALLOW"))
});

let on_start: Box<dyn FnMut() + Send + Sync> =
    Box::new(|| info!("+++++++ echo server started! +++++++"));

RSocketFactory::receive()
    .transport(transport)
    .acceptor(responder)
    .on_start(on_start)
    .serve()
    .await?;

Ok(())

}

```

Client

```rust use log::info; use rsocketrust::prelude::*; use rsocketrust::Result; use rsocketrusttransport_websocket::WebsocketClientTransport;

[tokio::main]

async fn main() -> Result<()> { let client = RSocketFactory::connect() .transport(WebsocketClientTransport::from("127.0.0.1:8080")) .setup(Payload::from("READY!")) .mime_type("text/plain", "text/plain") .start() .await?;

let request_payload = Payload::builder()
    .set_data_utf8("Hello World!")
    .set_metadata_utf8("Rust")
    .build();

let res = client.request_response(request_payload).await?;

info!("got: {:?}", res);

client.close();

Ok(())

} ```