Struct Librecast 

pub struct Librecast { /* private fields */ }

Implementations

impl Librecast

pub fn new() -> Result<Self>

Create a new librecast context

Examples found in repository

examples/sender.rs (line 8)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create a new librecast context
    let librecast = Librecast::new()?;

    // Create a channel using the builder pattern
    let channel = librecast
        .channel_builder()
        .name("example-channel")
        .enable_raptorq()
        .enable_loopback()
        .build()?;

    // Join the channel
    channel.join()?;

    // Rate limits the channel to 100Mbps
    channel.rate_limit(104857600)?;

    // Send a message
    let data = b"Hello, Librecast!";
    channel
        .send(data)
        .expect("Failed to send data on the channel");

    // Leave the channel
    channel.leave()?;

    Ok(())
}

examples/receiver.rs (line 8)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create a new librecast context
    let librecast = Librecast::new()?;

    // Create a channel using the builder pattern
    let channel = librecast
        .channel_builder()
        .name("example-channel")
        .enable_raptorq()
        .build()?;

    // Join the channel
    channel.join()?;

    // Receive a message
    let mut buffer = vec![0u8; 1024]; // Buffer to hold received data
    match channel.receive(&mut buffer) {
        Ok(size) => {
            // Process the received data
            let received_data = &buffer[..size];
            println!(
                "Received data: {:?}",
                String::from_utf8_lossy(received_data)
            );
        }
        Err(e) => {
            eprintln!("Failed to receive data: {}", e);
        }
    }

    // Leave the channel
    channel.leave()?;

    Ok(())
}

pub fn channel_builder(&self) -> ChannelBuilder<'_>

Get a builder for creating a new channel

Examples found in repository

examples/sender.rs (line 12)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create a new librecast context
    let librecast = Librecast::new()?;

    // Create a channel using the builder pattern
    let channel = librecast
        .channel_builder()
        .name("example-channel")
        .enable_raptorq()
        .enable_loopback()
        .build()?;

    // Join the channel
    channel.join()?;

    // Rate limits the channel to 100Mbps
    channel.rate_limit(104857600)?;

    // Send a message
    let data = b"Hello, Librecast!";
    channel
        .send(data)
        .expect("Failed to send data on the channel");

    // Leave the channel
    channel.leave()?;

    Ok(())
}

examples/receiver.rs (line 12)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create a new librecast context
    let librecast = Librecast::new()?;

    // Create a channel using the builder pattern
    let channel = librecast
        .channel_builder()
        .name("example-channel")
        .enable_raptorq()
        .build()?;

    // Join the channel
    channel.join()?;

    // Receive a message
    let mut buffer = vec![0u8; 1024]; // Buffer to hold received data
    match channel.receive(&mut buffer) {
        Ok(size) => {
            // Process the received data
            let received_data = &buffer[..size];
            println!(
                "Received data: {:?}",
                String::from_utf8_lossy(received_data)
            );
        }
        Err(e) => {
            eprintln!("Failed to receive data: {}", e);
        }
    }

    // Leave the channel
    channel.leave()?;

    Ok(())
}

Trait Implementations

impl Drop for Librecast

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Send for Librecast