Struct TitanClient 

pub struct TitanClient { /* private fields */ }

Titan Exchange WebSocket client.

Thread-safe client for interacting with the Titan Exchange API. Can be shared across axum handlers via Arc<TitanClient>.

Implementations

impl TitanClient

pub async fn new(config: TitanConfig) -> Result<Self, TitanClientError>

Create a new client with the given configuration.

Connects eagerly and fetches server info to determine stream limits.

pub async fn state_receiver(&self) -> Receiver<ConnectionState>

Returns a watch receiver for connection state changes.

Use this to observe state transitions (Connected, Reconnecting, Disconnected).

pub async fn state(&self) -> ConnectionState

Get the current connection state.

pub async fn is_connected(&self) -> bool

Returns true if currently connected.

pub async fn wait_for_connected(&self) -> Result<(), TitanClientError>

Wait until the connection is established.

Returns immediately if already connected. Returns error if connection is permanently closed.

pub async fn active_stream_count(&self) -> u32

Get the current active stream count.

pub async fn queued_stream_count(&self) -> usize

Get the current queue length.

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

Graceful shutdown: stops all streams, then closes WebSocket.

This method:

1. Sends StopStream for all active streams
2. Clears the stream manager
3. Closes the WebSocket connection

After calling this, the client cannot be reused.

pub async fn is_closed(&self) -> bool

Check if the client has been closed.

pub async fn get_info(&self) -> Result<ServerInfo, TitanClientError>

Get server info and connection limits.

pub async fn get_venues(&self) -> Result<VenueInfo, TitanClientError>

Get available venues.

pub async fn list_providers( &self, ) -> Result<Vec<ProviderInfo>, TitanClientError>

List available providers.

pub async fn get_swap_price( &self, request: SwapPriceRequest, ) -> Result<SwapPrice, TitanClientError>

Get a point-in-time swap price.

pub async fn new_swap_quote_stream( &self, request: SwapQuoteRequest, ) -> Result<QuoteStream, TitanClientError>

Start a new swap quote stream.

Returns a QuoteStream that yields SwapQuotes updates. The stream automatically sends StopStream when dropped.

If the server’s max concurrent streams limit is reached, the request will be queued and started automatically when a slot becomes available.