Struct StdioBroker 

pub struct StdioBroker { /* private fields */ }

Standard input and output as one stream: consume lines from stdin, publish lines to stdout, in the client’s [timestamp | stream_key | seq] payload line format.

Examples

use ruststream_sea_file::StdioBroker;

let broker = StdioBroker::new();

Implementations

impl StdioBroker

pub fn new() -> Self

Records configuration only. No I/O.

pub fn loopback(self) -> Self

Loops published messages back to this process’s own subscribers (for tests).

pub fn publisher(&self) -> StdioPublisher

A publisher sharing this broker’s connection cell; buildable before connect.

Trait Implementations

impl Broker for StdioBroker

type Error = SeaFileError

The error type returned by broker-level operations.

type Connected = ConnectedStdioBroker

The connected form of this broker: the typed witness that connect succeeded.

async fn connect(self) -> Result<Self::Connected, Self::Error>

Establishes the connection to the broker, consuming the unconnected form.

fn bindable(self) -> Bindable<Self>

where Self: 'static,

Wraps the broker for publisher-token minting before registration: the returned Bindable hands out Bound tokens via its bind, and is itself what with_broker takes.

impl Clone for StdioBroker

fn clone(&self) -> StdioBroker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StdioBroker

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

Formats the value using the given formatter.

impl Default for StdioBroker

fn default() -> StdioBroker

Returns the “default value” for a type.

impl DescribeServer for StdioBroker

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.