Struct PhantomStream 

pub struct PhantomStream { /* private fields */ }

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