Struct MdFrame 

pub struct MdFrame {
    pub sub: SubscriptionId,
    pub event: MdEvent,
}

One stream event of one subscription.

Fields

sub: SubscriptionId

The subscription whose stream produced the event.

event: MdEvent

What happened on that stream.

Implementations

impl MdFrame

pub fn lifecycle(sub: SubscriptionId, ev: StreamEvent<()>) -> Option<Self>

Frame for a stream lifecycle event (connected, disconnected, failed).

None for StreamEvent::Msg, because a message has its own typed variant of MdEvent.

Examples

use brokapi_core::SubscriptionId;
use brokapi_finam::core::{MdEvent, MdFrame, StreamEvent};

let sub = SubscriptionId::new(1);
let frame = MdFrame::lifecycle(sub, StreamEvent::Connected).unwrap();
assert!(matches!(frame.event, MdEvent::Connected));
assert!(MdFrame::lifecycle(sub, StreamEvent::Msg(())).is_none());

Trait Implementations

impl Clone for MdFrame

fn clone(&self) -> MdFrame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MdFrame

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

Formats the value using the given formatter.