Connector (algostream.Algostream_data_ingestion

include Algostream_data_ingestion.Exchange.S

val name : string

val build_subscribe_message : symbols:string list -> string

Build the subscribe message sent right after WebSocket upgrade.

val parse_frame : 
  symbol_intern:Algostream_data_ingestion.Symbol_intern.t ->
  string ->
  Algostream_infrastructure_event_bus.Event_types.Event.payload list

Decode a raw text frame payload into zero or more event-bus payloads.

symbol_intern is a per-Domain interner so symbol strings reuse storage across calls. Returns an empty list for unrecognised / control frames (subscribe ack, pong, etc.).