Struct NativeStreamHandle 

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

Typed, immutable stream endpoints materialized before App boot completes.

Implementations

impl<C: StreamCapability> NativeStreamHandle<C>

pub fn binding_count(&self) -> usize

Returns the number of provider endpoints captured by this handle.

pub async fn open( &self, operation: &str, request: C::OpenRequest, ) -> Result<Result<NativeStream<C>, C::DomainError>, RuntimeFailure>

Opens one stream with a fresh invocation context.

pub async fn open_with_context( &self, operation: &str, context: InvocationContext, request: C::OpenRequest, ) -> Result<Result<NativeStream<C>, C::DomainError>, RuntimeFailure>

Opens one stream with an explicit propagated Invocation Context.

Trait Implementations

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

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

Formats the value using the given formatter.