An asynchronous WAMP client implementation written in rust.
For usage examples, see :
- Publisher/Subscriber
rust
// Publish event with no arguments and with acknowledgment
let ack_id = client.publish("peer.heartbeat", None, None, true).await?;
println!("Ack id {}", ack_id.unwrap());
rust
// Register for events
let (_sub_id, mut event_queue) = client.subscribe("peer.heartbeat").await?;
// Wait for the next event
match event_queue.recv().await {
Some((_pub_id, args, kwargs)) => println!("Event(args: {:?}, kwargs: {:?})", args, kwargs),
None => println!("Event queue closed"),
};
- RPC caller & callee
rust
// Call endpoint with one argument
let (args, kwargs) = client.call("peer.echo", Some(vec![Arg::Integer(12)]), None).await?;
println!("RPC returned {:?} {:?}", args, kwargs);
```rust
// Declare your RPC function
async fn rpc_echo(args: WampArgs, kwargs: WampKwArgs) -> Result<(WampArgs, WampKwArgs), WampError> {
println!("peer.echo {:?} {:?}", args, kwargs);
Ok((args, kwargs))
}
// Register the function let rpcid = client.register("peer.echo", rpcecho).await?; ```
| Feature | Desciption | Status | |---------|------------|--------| |Websocket| Use websocket as the transport | ✔ | |Secure Websocket| Websocket over HTTPS | ✔ | | RawSocket | Use lightweight TCP as the transport | ✔ | | Secure RawSocket | RawSocket with TLS | ✔ | |MsgPack| Use MessagePack for message serialization | ✔ | |JSON | Uses JSON for message serialization | ✔ |
| Feature | Desciption | Status | |---------|------------|--------| | Publisher | Ability to publish messages on topics | ✔ | | Subscriber | Can subscribe and receive events for a topic | ✔ | | Caller | Ability to call RPC endpoints | ✔ | | Callee | Ability to register RPC endpoints | ✔ |
TODO
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.