Module websocket 

WebSocket stream source adapter WebSocket stream source adapter.

Implements [StreamSourcePort] and [ScrapingService] for consuming WebSocket feeds. Uses tokio-tungstenite for the underlying connection.

Example

use stygian_graph::adapters::websocket::WebSocketSource;
use stygian_graph::ports::stream_source::StreamSourcePort;

let source = WebSocketSource::default();
let events = source.subscribe("wss://api.example.com/ws", Some(10)).await.unwrap();
println!("received {} events", events.len());

Structs

WebSocketConfig

Configuration for a WebSocket connection.

WebSocketSource

WebSocket stream source adapter.