Skip to main content

LogStream

Type Alias LogStream 

Source
pub type LogStream = ReceiverStream<ColdResult<RpcLog>>;
Expand description

A stream of log results backed by a bounded channel.

Each item is a ColdResult<RpcLog>. The stream produces Ok(log) items until complete, or yields a final Err(e) on failure. The stream ends (None) when all matching logs have been delivered or after an error.

§Partial Delivery

One or more Ok(log) items may be delivered before a terminal Err(...). Consumers must be prepared for partial results — for example, a reorg or deadline expiry can interrupt a stream that has already yielded some logs.

§Resource Management

The stream holds a backend concurrency permit. Dropping the stream releases the permit. Drop early if results are no longer needed.

Aliased Type§

pub struct LogStream { /* private fields */ }