Struct WebSocketTransport 

pub struct WebSocketTransport<N: NetworkProvider> { /* private fields */ }

WebSocket-based StreamTransport implementation.

Generic over the NetworkProvider type N. Owns a shared reference to Layer 3 for establishing raw TCP connections, and a WsConfig for protocol parameters.

Example

use std::sync::Arc;
use truffle_core::transport::{WsConfig, websocket::WebSocketTransport};

let ws = WebSocketTransport::new(Arc::new(provider), WsConfig::default());
let stream = ws.connect(&peer_addr).await?;

Implementations

impl<N: NetworkProvider + 'static> WebSocketTransport<N>

pub fn new(network: Arc<N>, config: WsConfig) -> Self

Create a new WebSocket transport.

• network: An Arc<N> where N: NetworkProvider.
• config: WebSocket configuration (port, heartbeat intervals, etc.).

Trait Implementations

impl<N: NetworkProvider + 'static> StreamTransport for WebSocketTransport<N>

type Stream = WsFramedStream

The framed stream type produced by this transport.

async fn connect(&self, addr: &PeerAddr) -> Result<Self::Stream, TransportError>

Connect to a peer address and return a framed bidirectional stream.

async fn listen(&self) -> Result<StreamListener<Self::Stream>, TransportError>

Start listening for incoming framed connections.