Struct ReadStream 

pub struct ReadStream {
    pub subscriber_handle: ObjectId,
    pub topic_handle: ObjectId,
    pub delivery_control: DeliveryControl,
    /* private fields */
}

Pro-READ_DATA-Request gehaltener Stream-State.

Fields

subscriber_handle: ObjectId

Subscriber-Object, dem der ReadStream zugeordnet ist.

topic_handle: ObjectId

Topic-Object, das gelesen wird.

delivery_control: DeliveryControl

Delivery-Control mit allen Limits.

Implementations

impl ReadStream

pub fn new( subscriber_handle: ObjectId, topic_handle: ObjectId, delivery_control: DeliveryControl, now: Duration, ) -> Self

Konstruktor.

pub fn is_finalized(&self) -> bool

true, wenn der Stream abgeschlossen ist.

pub fn samples_delivered(&self) -> u32

Anzahl bereits gelieferter Samples.

pub fn push_sample(&mut self, sample: PendingSample)

App-Schicht reicht ein neues Sample ein.

pub fn queued_count(&self) -> usize

Anzahl wartender Samples (noch nicht ausgeliefert).

pub fn pull_pending_samples(&mut self, now: Duration) -> Vec<PendingSample>

Pull-Tick: liefert die Samples, die jetzt rate-konform ausgegeben werden duerfen. now ist uptime-relativ.

pub fn stop(&mut self)

Stoppt den Stream sofort (z.B. bei DELETE des Subscribers).

Trait Implementations

impl Clone for ReadStream

fn clone(&self) -> ReadStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadStream

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

Formats the value using the given formatter.