Enum DataLane 

pub enum DataLane {
    WebRtcDataChannel {
        data_channel: Arc<RTCDataChannel>,
        rx: Arc<Mutex<Receiver<Bytes>>>,
    },
    Mpsc {
        payload_type: PayloadType,
        tx: Sender<RpcEnvelope>,
        rx: Arc<Mutex<Receiver<RpcEnvelope>>>,
    },
    WebSocket {
        sink: Arc<Mutex<Option<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>>,
        payload_type: PayloadType,
        rx: Arc<Mutex<Receiver<Bytes>>>,
    },
}

DataLane - Data transport channel

Each DataLane represents a specific transport path for data/message transmission. MediaTrack uses a separate path via MediaFrameRegistry, not DataLane.

Variants

WebRtcDataChannel

WebRTC DataChannel Lane

For transmitting messages via WebRTC DataChannel

Fields

data_channel: Arc<RTCDataChannel>

Underlying DataChannel

rx: Arc<Mutex<Receiver<Bytes>>>

Receive channel (shared, uses Bytes for zero-copy)

Mpsc

Mpsc Lane

For intra-process communication (Inproc transport)

Note: directly passes RpcEnvelope objects, zero serialization

Fields

payload_type: PayloadType

PayloadType identifier

tx: Sender<RpcEnvelope>

Send channel (directly passes RpcEnvelope)

rx: Arc<Mutex<Receiver<RpcEnvelope>>>

Receive channel (shared)

WebSocket

WebSocket Lane

For business data transmission in C/S architecture

Fields

sink: Arc<Mutex<Option<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>>

Shared Sink (all PayloadTypes share the same WebSocket connection) Uses Option to support lazy initialization

payload_type: PayloadType

PayloadType identifier (used to add message header when sending)

rx: Arc<Mutex<Receiver<Bytes>>>

Receive channel (independent, routed by dispatcher, uses Bytes for zero-copy)

Implementations

impl DataLane

pub async fn send(&self, data: Bytes) -> NetworkResult<()>

Send message

Arguments

• data: message data (uses Bytes for zero-copy)

Example

use bytes::Bytes;
data_lane.send(Bytes::from_static(b"hello")).await?;

pub async fn send_envelope(&self, envelope: RpcEnvelope) -> NetworkResult<()>

Send RpcEnvelope (Inproc only, zero serialization)

Arguments

• envelope: RpcEnvelope object

Description

This method is only for DataLane::Mpsc, directly passing RpcEnvelope objects, without serialization/deserialization, achieving zero-copy intra-process communication.

Example

use actr_protocol::RpcEnvelope;
let envelope = RpcEnvelope { /* ... */ };
data_lane.send_envelope(envelope).await?;

pub async fn recv(&self) -> NetworkResult<Bytes>

Receive message

Blocks until a message is received or the channel is closed.

Returns

• Ok(Bytes): received message data (zero-copy)
• Err: channel closed or other error

Example

let data = data_lane.recv().await?;
println!("Received {} bytes", data.len());

pub async fn recv_envelope(&self) -> NetworkResult<RpcEnvelope>

Receive RpcEnvelope (Inproc only)

Returns

• Ok(RpcEnvelope): received message object
• Err: channel closed

Description

This method is only for DataLane::Mpsc, directly receiving RpcEnvelope objects, zero-copy.

pub async fn try_recv(&self) -> NetworkResult<Option<Bytes>>

Try to receive message (non-blocking)

Returns

• Ok(Some(data)): received message (zero-copy)
• Ok(None): no message available
• Err: channel closed or other error

pub fn lane_type(&self) -> &'static str

Get DataLane type name (for logging)

impl DataLane

DataLane factory methods

pub fn mpsc( payload_type: PayloadType, tx: Sender<RpcEnvelope>, rx: Receiver<RpcEnvelope>, ) -> Self

Create Mpsc DataLane (accepts plain Receiver)

Arguments

• payload_type: PayloadType identifier
• tx: send channel (directly passes RpcEnvelope)
• rx: receive channel (automatically wrapped in Arc<Mutex<>>)

pub fn mpsc_shared( payload_type: PayloadType, tx: Sender<RpcEnvelope>, rx: Arc<Mutex<Receiver<RpcEnvelope>>>, ) -> Self

Create Mpsc DataLane (accepts shared Receiver)

Arguments

• payload_type: PayloadType identifier
• tx: send channel (directly passes RpcEnvelope)
• rx: shared receive channel

pub fn webrtc_data_channel( data_channel: Arc<RTCDataChannel>, rx: Receiver<Bytes>, ) -> Self

Create WebRTC DataChannel DataLane

Arguments

• data_channel: DataChannel reference
• rx: receive channel (Bytes zero-copy)

pub fn websocket( sink: Arc<Mutex<Option<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>>, payload_type: PayloadType, rx: Receiver<Bytes>, ) -> Self

Create WebSocket DataLane

Arguments

• sink: shared WebSocket Sink (may not be connected yet, uses Option)
• payload_type: message type identifier
• rx: receive channel (Bytes zero-copy)

Trait Implementations

impl Clone for DataLane

fn clone(&self) -> DataLane

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataLane

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.