Enum StreamMessage 

pub enum StreamMessage {
    Authenticated,
    Subscribed {
        data: SubscribedData,
    },
    Snapshot {
        id: String,
        channel: String,
        payload: SnapshotPayload,
    },
    Data {
        id: String,
        channel: String,
        payload: DataPayload,
    },
    Error {
        data: ErrorData,
    },
    Pong {
        state: Option<String>,
    },
}

Top-level WebSocket message

Uses serde’s internally tagged enum to parse based on “event” field.

Example

use marketdata_core::models::streaming::StreamMessage;

let json = r#"{"event": "authenticated"}"#;
let msg: StreamMessage = serde_json::from_str(json).unwrap();
assert!(matches!(msg, StreamMessage::Authenticated));

Variants

Authenticated

Authentication successful

Subscribed

Subscription confirmed

Fields

data: SubscribedData

Subscription confirmation payload.

Snapshot

Snapshot after subscription (channel-specific)

Fields

id: String

Subscription ID

channel: String

Channel name

payload: SnapshotPayload

Snapshot payload (channel-specific, parsed later)

Data

Real-time data (channel-specific)

Fields

id: String

Subscription ID

channel: String

Channel name

payload: DataPayload

Data payload (channel-specific, parsed later)

Error

Error event

Fields

data: ErrorData

Server-supplied error details.

Pong

Pong response (health check)

Fields

state: Option<String>

Optional server-reported connection state (e.g. "alive").

Trait Implementations

impl Clone for StreamMessage

fn clone(&self) -> StreamMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.