Struct StreamSource 

pub struct StreamSource { /* private fields */ }

A data source that receives monitor snapshots from an async stream.

This source spawns a background task that reads newline-delimited JSON from the provided async reader and makes snapshots available via poll().

Example with a byte stream

use std::io::Cursor;
use buswatch_tui::StreamSource;

let data = b"{}\n";
let stream = Cursor::new(data.to_vec());
let source = StreamSource::spawn(stream, "example");

Implementations

impl StreamSource

pub fn spawn<R>(reader: R, description: &str) -> Self

where R: AsyncRead + Unpin + Send + 'static,

Spawn a background task that reads from the given async reader.

The reader should provide newline-delimited JSON snapshots. Each line is parsed as a complete MonitorSnapshot.

pub fn from_bytes_channel(rx: Receiver<Vec<u8>>, description: &str) -> Self

Create a StreamSource from a raw bytes channel.

This is useful when you want to push JSON bytes from another source (like a message bus) without using an AsyncRead.

Each Vec<u8> sent through the channel should be a complete JSON snapshot.

impl StreamSource

pub fn last_error(&self) -> Option<String>

Get the last error message, if any.

Trait Implementations

impl DataSource for StreamSource

fn poll(&mut self) -> Option<Snapshot>

Poll for the latest snapshot.

fn description(&self) -> &str

Returns a human-readable description of the source.

fn error(&self) -> Option<&str>

Check if the source has encountered an error.

impl Debug for StreamSource

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

Formats the value using the given formatter.