Pushing data to Bytebeam

Learn how to push data to streams using ByteBeam Client with this comprehensive document. Includes a Rust code example for publishing data, emphasizing the need for JSON serialization. Discover the best practices, including omitting “id” and “timestamp” f

You can use ByteBeam Client to push data to Streams. Follow Creating a Stream guide to create streams.

pub fn publish_to_stream(
        &self, // Bytebeam Client
        stream_name: &str,
        sequence: u32,
        payload: impl Serialize,
    ) -> anyhow::Result<u32>

Payload you want to publish must be something that can be Serialized to JSON.

Lets say you have “led_status” stream with field “status”. You can create a struct and use serde::Serialize attribute.

#[derive(Serialize)]
struct LedStream {
    // your custom fields!
    status: String,
}

fn main() {
    // ....
    let bytebeam_client = ByteBeamClient::init()?;

    let sequence = 1;
    let message = LedStream {
        status: "ON".into(),
    };

    // You can remove .expect and handle the error
    bytebeam_client
        .publish_to_stream("led_status", sequence, message)
        .expect("published successfully");
    //...
}

NOTE: Every stream has id and timestamp fields as well, we add them internally, so it is recommended to not include them in your custom struct!

**