siderite

Rust client library for Meteor DDP.

Currently extremely limited (no actual object synchronisation), but useable for connecting, making RPC calls and receiving subscription messages by hand.

lib.rs:

A simple wrapper for the Meteor DDP protocol.

let connection = siderite::Connection::connect("wss://example.com/websocket").await?;

// Make a RPC task in an independant task:
let handle = connection.handle();
tokio::spawn(async move {
    let r = handle.call("login", vec!["username".into(), "my-secret-token".into()])
                       .await?;  // this throws if the RPC call could not complete
                       .map_err(|e| eprintln!("Login failed with reason: {}", e))?

    ...
});

// Consume the stream
while let Some(msg) = connection.recv().await {
   match msg {
      ServerMessage::Added{..} => { ... }
   }
}