Enum OutGate 

pub enum OutGate {
    InprocOut(Arc<InprocOutGate>),
    OutprocOut(Arc<OutprocOutGate>),
}

OutGate - 出站消息门枚举

设计原则

• 使用 enum dispatch 而非 trait object，避免虚函数调用
• 零成本抽象：编译时准确确定类型
• 完全独立：仅用于出站（Outbound），不包含任何入站路由逻辑

性能

OutGate::send_request() 内部：
  match self {
      OutGate::InprocOut(gate) => gate.send_request(...),   // ← 静态分发
      OutGate::OutprocOut(gate) => gate.send_request(...),  // ← 静态分发
  }

性能：
  - 无虚函数表查找
  - 编译器完全内联
  - CPU 分支预测命中率 >95%

Variants

InprocOut(Arc<InprocOutGate>)

InprocOut - 进程内传输（零序列化，出站）

OutprocOut(Arc<OutprocOutGate>)

OutprocOut - 跨进程传输（Protobuf 序列化，出站）

Implementations

impl OutGate

pub async fn send_request( &self, target: &ActrId, envelope: RpcEnvelope, ) -> ActorResult<Bytes>

发送请求并等待响应

参数

• target: 目标 Actor ID
• envelope: 消息信封（包含 route_key 和 payload）

返回

返回响应的字节数据

实现

使用 enum dispatch 静态分发到对应的实现：

• InprocOut: 零序列化，直接传递 RpcEnvelope
• OutprocOut: Protobuf 序列化，通过 Transport 层发送

pub async fn send_request_with_type( &self, target_id: &ActrId, payload_type: PayloadType, envelope: RpcEnvelope, ) -> ActorResult<Bytes>

发送请求并等待响应（显式指定 PayloadType）

pub async fn send_message( &self, target: &ActrId, envelope: RpcEnvelope, ) -> ActorResult<()>

发送单向消息（不等待响应）

参数

• target: 目标 Actor ID
• envelope: 消息信封

语义

Fire-and-forget：发送后立即返回，不等待响应

pub async fn send_message_with_type( &self, target: &ActrId, payload_type: PayloadType, envelope: RpcEnvelope, ) -> ActorResult<()>

发送单向消息（显式指定 PayloadType）

pub async fn send_media_sample( &self, target: &ActrId, track_id: &str, sample: MediaSample, ) -> ActorResult<()>

发送媒体样本（WebRTC native media）

参数

• target: 目标 Actor ID
• track_id: Media track 标识符
• sample: 媒体样本数据

语义

• 仅支持 OutprocOut（WebRTC）
• InprocOut 返回 NotImplemented 错误
• 使用 WebRTC RTCRtpSender 发送，无 protobuf 开销

pub async fn send_data_stream( &self, target: &ActrId, payload_type: PayloadType, data: Bytes, ) -> ActorResult<()>

发送 DataStream（Fast Path 数据流）

参数

• target: 目标 Actor ID
• payload_type: PayloadType (StreamReliable 或 StreamLatencyFirst)
• data: 序列化后的 DataStream bytes

语义

• InprocOut: 通过 mpsc channel 发送
• OutprocOut: 通过 WebRTC DataChannel 或 WebSocket 发送

Trait Implementations

impl Clone for OutGate

fn clone(&self) -> OutGate

Returns a duplicate of the value.

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

Performs copy-assignment from source.