Struct ProviderStreamChannel 

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

The typed provider side of one bounded bidirectional Stream session.

Plugin code uses this channel to exchange Capability values. Generated lowering keeps type erasure and NativeStreamSession behind the facade.

Implementations

impl<C: StreamCapability> ProviderStreamChannel<C>

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

Sends one typed message with bounded backpressure.

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

Closes only the provider’s sending direction.

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

Completes the Stream successfully.

pub async fn fail( &mut self, error: C::DomainError, ) -> Result<(), RuntimeFailure>

Completes the Stream with a Capability-defined Domain Error.

pub async fn fail_runtime( &mut self, error: RuntimeFailure, ) -> Result<(), RuntimeFailure>

Completes the Stream with an infrastructure Runtime Failure.

pub async fn complete( self, result: PluginResult<(), C::DomainError>, ) -> Result<(), RuntimeFailure>

Closes the provider send direction and completes the Stream exactly once.

Consuming the channel prevents Plugin code from accidentally sending or terminating the session again after its operation result is known.

pub async fn receive(&mut self) -> Result<StreamInput<C>, RuntimeFailure>

Receives the next typed consumer message or half-close marker.

pub fn is_cancelled(&self) -> bool

Returns whether the consumer cancelled this Stream.

Trait Implementations

impl<C: StreamCapability> Debug for ProviderStreamChannel<C>

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

Formats the value using the given formatter.