Struct NativeStream 

pub struct NativeStream<C: StreamCapability> { /* private fields */ }

One opened, typed bidirectional stream session.

Implementations

impl<C: StreamCapability> NativeStream<C>

pub async fn send(&self, message: C::Message) -> Result<(), RuntimeFailure>

Sends one typed message to the remote side.

pub async fn receive( &self, ) -> Result<StreamEvent<C::Message, C::DomainError>, RuntimeFailure>

Receives the next ordered event from the remote side.

pub async fn close_send(&self) -> Result<(), RuntimeFailure>

Closes this side’s sending direction while keeping receiving available.

pub fn cancel(&self)

Cancels the stream idempotently. No later frame is delivered to the caller.

pub const fn request_id(&self) -> RequestId

Returns the propagated Kernel Request ID for this stream.

Trait Implementations

impl<C: Debug + StreamCapability> Debug for NativeStream<C>

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

Formats the value using the given formatter.

impl<C: StreamCapability> Drop for NativeStream<C>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.