Stock Full Trades

Streams every trade print across the entire stock universe — one subscription, no per-symbol management. For each traded symbol the stream delivers three events, not just the trade: a Quote (the last BBO), an Ohlcvc bar, and then the Trade print itself. Read the symbol off each event's contract.

The snippets below assume a connected client with streaming started — see Getting Started for the connect-and-stream ladder.

use thetadatadx::streaming::SecTypeExt;
use thetadatadx::streaming::{StreamData, StreamEvent};
use thetadatadx::SecType;

client.stream().start_streaming(|event: &StreamEvent| match event {
    StreamEvent::Data(StreamData::Quote { contract, bid, ask, .. }) => {
        println!("{} quote bid={bid} ask={ask}", contract.symbol);
    }
    StreamEvent::Data(StreamData::Ohlcvc { contract, open, high, low, close, .. }) => {
        println!("{} bar o={open} h={high} l={low} c={close}", contract.symbol);
    }
    StreamEvent::Data(StreamData::Trade { contract, price, size, .. }) => {
        println!("{} trade price={price} size={size}", contract.symbol);
    }
    _ => {}
})?;

let sub = SecType::Stock.full_trades();
client.stream().subscribe(sub.clone())?;

// Remove this stream; the session stays open for other subscriptions.
client.stream().unsubscribe(sub)?;

from thetadatadx import SecType

def on_event(event):
    if event.kind == "quote":
        print(event.contract.symbol, "quote", event.bid, event.ask)
    elif event.kind == "ohlcvc":
        print(event.contract.symbol, "bar", event.open, event.high, event.low, event.close)
    elif event.kind == "trade":
        print(event.contract.symbol, "trade", event.price, event.size)

client.stream.start_streaming(on_event)

sub = SecType.STOCK.full_trades()
client.stream.subscribe(sub)

# Remove this stream; the session stays open for other subscriptions.
client.stream.unsubscribe(sub)

import { SecType } from 'thetadatadx-ts';

await client.stream.startStreaming((event) => {
  switch (event.kind) {
    case 'quote': {
      const q = event.quote!;
      console.log(q.contract.symbol, 'quote', q.bid, q.ask);
      break;
    }
    case 'ohlcvc': {
      const b = event.ohlcvc!;
      console.log(b.contract.symbol, 'bar', b.open, b.high, b.low, b.close);
      break;
    }
    case 'trade': {
      const t = event.trade!;
      console.log(t.contract.symbol, 'trade', t.price, t.size);
      break;
    }
  }
});

const sub = SecType.stock().fullTrades();
client.stream.subscribe(sub);

// Remove this stream; the session stays open for other subscriptions.
client.stream.unsubscribe(sub);

client.stream().set_callback([](const thetadatadx::StreamEvent& event) {
    switch (event.kind) {
        case THETADATADX_STREAM_QUOTE:
            std::cout << event.quote.contract.symbol << " quote bid=" << event.quote.bid << " ask=" << event.quote.ask << "\n";
            break;
        case THETADATADX_STREAM_OHLCVC:
            std::cout << event.ohlcvc.contract.symbol << " bar o=" << event.ohlcvc.open << " c=" << event.ohlcvc.close << "\n";
            break;
        case THETADATADX_STREAM_TRADE:
            std::cout << event.trade.contract.symbol << " trade price=" << event.trade.price << " size=" << event.trade.size << "\n";
            break;
        default:
            break;
    }
});

auto sub = thetadatadx::SecType::stock().full_trades();
client.stream().subscribe(sub);

// Remove this stream; the session stays open for other subscriptions.
client.stream().unsubscribe(sub);

GET ws://127.0.0.1:25520/v1/events

WebSocket streaming from the bundled server binary. Send one JSON envelope per command; set "add": false to unsubscribe.

Example

websocat ws://127.0.0.1:25520/v1/events
{"msg_type": "STREAM", "sec_type": "STOCK", "req_type": "FULL_TRADES", "id": 1, "add": true}

What the stream delivers

This is not a trade-only feed. For every traded contract the stream delivers three event types: a Quote, an Ohlcvc bar, and the Trade print. The Quote (the last BBO) and the Ohlcvc bar are sent automatically before the trade occurs, then the Trade follows. Narrow on event.kind (quote / ohlcvc / trade) to handle each, and read the contract identity off every event's contract.

Per-contract sequence

quote  QQQ  bid/ask (last BBO)
ohlcvc QQQ  open/high/low/close, volume, count
trade  QQQ  price, size, exchange, condition

OHLC bars

The Ohlcvc bars on this stream come from upstream automatically — one is sent for each traded contract before its trade, you do not subscribe to them separately.

Before you subscribe

• This stream requires a Stocks Pro subscription.
• Each new stream request must use a higher id than the last; reusing an id stops the terminal from automatically resubscribing your earlier streams after a reconnect. The SDK manages the id for you; the WebSocket envelope sets it explicitly.

Quote event fields

Each update arrives as a Quote event with these fields:

Field	Type	Description
contract	contract	Resolved contract identity (symbol, security type, and option fields).
ms_of_day	i32	Milliseconds since midnight Eastern Time.
bid_size	i32	Last BBO bid size.
bid_exchange	i32	Exchange code of the BBO bid.
bid	f64	Last BBO bid price.
bid_condition	i32	Quote condition code on the bid side.
ask_size	i32	Last BBO ask size.
ask_exchange	i32	Exchange code of the BBO ask.
ask	f64	Last BBO ask price.
ask_condition	i32	Quote condition code on the ask side.
date	i32	Trading date as a YYYYMMDD integer.
received_at_ns	u64	Local receive timestamp, nanoseconds since the Unix epoch.

The contract field carries symbol, the security type, and — for options — expiration, right, and the strike. See Handling Events for the full event catalogue and per-language field shapes.

Ohlcvc event fields

Each update arrives as a Ohlcvc event with these fields:

Field	Type	Description
contract	contract	Resolved contract identity (symbol, security type, and option fields).
ms_of_day	i32	Milliseconds since midnight Eastern Time.
open	f64	Opening trade price of the bar.
high	f64	Highest traded price of the bar.
low	f64	Lowest traded price of the bar.
close	f64	Closing traded price of the bar.
volume	i64	Number of contracts or shares traded in the bar.
count	i64	Number of trades in the bar.
date	i32	Trading date as a YYYYMMDD integer.
received_at_ns	u64	Local receive timestamp, nanoseconds since the Unix epoch.

The contract field carries symbol, the security type, and — for options — expiration, right, and the strike. See Handling Events for the full event catalogue and per-language field shapes.

Trade event fields

Each update arrives as a Trade event with these fields:

Field	Type	Description
contract	contract	Resolved contract identity (symbol, security type, and option fields).
ms_of_day	i32	Milliseconds since midnight Eastern Time.
sequence	i32	Exchange-assigned trade sequence number.
condition	i32	Trade condition code.
size	i32	Number of contracts or shares traded.
exchange	i32	Exchange code where the trade executed.
price	f64	Trade price.
date	i32	Trading date as a YYYYMMDD integer.
received_at_ns	u64	Local receive timestamp, nanoseconds since the Unix epoch.

The contract field carries symbol, the security type, and — for options — expiration, right, and the strike. See Handling Events for the full event catalogue and per-language field shapes.

WebSocket frame

The native SDK callbacks (Rust/Python/TypeScript/C++) receive every field above. Each raw WebSocket frame (the Server tab) is { "header": {…}, "contract": {…}, "trade": {…} }: header and contract are always present, while the trade payload object carries only the terminal-compatible subset: ms_of_day, sequence, size, condition, price, exchange, date. The remaining event fields are delivered to the SDK callbacks, not the trade payload object.