Struct PythLazerWSConnection 

pub struct PythLazerWSConnection { /* private fields */ }

A WebSocket client for consuming Pyth Lazer price feed updates

This client provides a simple interface to:

• Connect to a Lazer WebSocket endpoint
• Subscribe to price feed updates
• Receive updates as a stream of messages

Implementations

impl PythLazerWSConnection

pub fn new(endpoint: Url, access_token: String) -> Result<Self>

Creates a new Lazer client instance

Arguments

• endpoint - The WebSocket URL of the Lazer service
• access_token - Access token for authentication

Returns

Returns a new client instance (not yet connected)

pub async fn start(&mut self) -> Result<impl Stream<Item = Result<AnyResponse>>>

Starts the WebSocket connection

Returns

Returns a stream of responses from the server

pub async fn send_request(&mut self, request: WsRequest) -> Result<()>

pub async fn subscribe(&mut self, request: SubscribeRequest) -> Result<()>

Subscribes to price feed updates

Arguments

• request - A subscription request containing feed IDs and parameters

pub async fn unsubscribe(&mut self, request: UnsubscribeRequest) -> Result<()>

Unsubscribes from a previously subscribed feed

Arguments

• subscription_id - The ID of the subscription to cancel

pub async fn close(&mut self) -> Result<()>

Closes the WebSocket connection