jetstream 16.0.0

Jetstream is a RPC framework for Rust, based on the 9P protocol and QUIC.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Example of WebAssembly compatibility for JetStream RPC
//!
//! This example demonstrates how to use JetStream RPC in a WebAssembly context.

use std::io::Cursor;

use jetstream_macros::JetStreamWireFormat;
use jetstream_wireformat::WireFormat;

#[derive(Debug, JetStreamWireFormat)]
struct Message {
    id: u32,
    content: String,
}

// This function would be exported to JavaScript in a real WebAssembly binary
fn encode_message(id: u32, content: String) -> Vec<u8> {
    let msg = Message { id, content };
    let mut buffer = Vec::new();
    msg.encode(&mut buffer).expect("Failed to encode message");
    buffer
}

// This function would be exported to JavaScript in a real WebAssembly binary
fn decode_message(buffer: &[u8]) -> (u32, String) {
    let mut cursor = Cursor::new(buffer);
    let msg: Message =
        WireFormat::decode(&mut cursor).expect("Failed to decode message");
    (msg.id, msg.content)
}

// Simple example function
fn main() {
    // Create a message
    let encoded = encode_message(42, "Hello from WebAssembly!".to_string());
    println!("Encoded message: {:?}", encoded);

    // Decode the message
    let (id, content) = decode_message(&encoded);
    println!("Decoded message: id={}, content=\"{}\"", id, content);
}