Struct StreamHandle 

pub struct StreamHandle {
    pub url: String,
    pub expires_at: String,
    /* private fields */
}

A live Void Stream handle. Write encrypted messages and close to self-destruct.

Fields

url: String

Shareable URL — share this with viewers (contains the decryption key)

expires_at: String

Implementations

impl StreamHandle

pub async fn write(&self, content: &str) -> Result<()>

Encrypt content client-side and push it to the stream.

pub async fn close(&self) -> Result<()>

Close the stream. Viewers receive a “closed” event and all content self-destructs.

pub fn watch(&self) -> impl Stream<Item = Result<String>> + Send + 'static

Watch the stream as an async Stream of decrypted messages.

Automatically reconnects using SSE Last-Event-ID until the stream closes or expires.

use futures::StreamExt;
// stream is a StreamHandle from create_stream()
let mut msgs = stream.watch();
while let Some(Ok(msg)) = msgs.next().await {
    println!("{msg}");
}

Trait Implementations

impl Debug for StreamHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.