Struct PhantomStream 

pub struct PhantomStream { /* private fields */ }

Available on crate feature std only.

A single multiplexed stream inside an established PhantomSession.

Created by the session’s stream multiplexer (one per logical stream id). Outbound data is queued to the session’s data pump over the tx command channel (send_reliable / send_unreliable); inbound demultiplexed data arrives on rx. The session owns all encryption and transport — a PhantomStream is just the per-stream send/recv handle exposed over FFI.

Implementations

impl PhantomStream

pub fn new(handle: StreamHandle, tx: Sender<SessionCommand>) -> Self

impl PhantomStream

pub fn stream_id(&self) -> u32

pub async fn send_reliable(&self, data: Vec<u8>) -> Result<(), CoreError>

pub async fn send_unreliable(&self, data: Vec<u8>) -> Result<(), CoreError>

pub async fn recv(&self) -> Result<Vec<u8>, CoreError>

pub async fn disconnect(&self) -> Result<(), CoreError>

Close this stream; the peer will see EOF on its read half.

Named disconnect rather than close for the same reason as PhantomSession::disconnect — UniFFI’s Kotlin generator emits AutoCloseable.close() on every object.

Trait Implementations

impl<UT> LiftRef<UT> for PhantomStream

type LiftType = Arc<PhantomStream>

impl<UT> LowerError<UT> for PhantomStream

fn lower_error(obj: Self) -> RustBuffer

Lower this value for scaffolding function return

impl<UT> LowerReturn<UT> for PhantomStream

type ReturnType = <Arc<PhantomStream> as LowerReturn<UniFfiTag>>::ReturnType

The type that should be returned by scaffolding functions for this type.

fn lower_return(obj: Self) -> Result<Self::ReturnType, RustCallError>

Lower the return value from an scaffolding call

fn handle_failed_lift( error: LiftArgsError, ) -> Result<Self::ReturnType, RustCallError>

Lower the return value for failed argument lifts

impl<UT> TypeId<UT> for PhantomStream

const TYPE_ID_META: MetadataBuffer