Expand description
WebSocket subscription request reading and JSON decoding. WebSocket subscription request reading and JSON decoding.
The first client frame on /events/stream is a JSON SubscriptionRequest.
This module owns the tolerant decode of that frame: the canonical proto
serde shape is accepted first, then the documented hand-written shapes
(per_workflow / filtered / firehose, optionally wrapped in
{"subscription": ...}).
Functionsยง
- decode_
subscription_ request - Decode a subscription request from raw frame bytes.
- read_
subscription_ request - Read the first subscription frame from an accepted WebSocket.