Struct Context 

pub struct Context<'a> { /* private fields */ }

Implementations

impl Context<'_>

pub fn context(&self) -> &CallContext

pub fn with_value<T: ContextValue>(&self, value: T) -> Result<Self>

pub fn id(&self) -> OperationInstanceId

pub fn attempt(&self) -> usize

pub fn scope(&self) -> &Scope<'_>

pub fn is_host_call(&self) -> bool

pub fn submit_at<O: OperationDeclaration>( &self, id: &str, request: O, ) -> Result<OperationInstance<O>>

pub fn submit<O: OperationDeclaration>( &self, request: O, ) -> Result<OperationInstance<O>>

pub fn submit_endpoints<O: OperationDeclaration, P: Send + 'static>( &self, request: O, endpoints: P, ) -> Result<OperationInstance<O>>

pub fn submit_charged<O: OperationDeclaration, P: Send + 'static>( &self, request: StreamItem<O>, endpoints: P, ) -> Result<OperationInstance<O>>

pub fn submit_caused<O: OperationDeclaration>( &self, request: O, cause: Position, ) -> Result<OperationInstance<O>>

pub async fn call_caused<O: OperationDeclaration>( &self, request: O, cause: Position, ) -> Result<Response<O::Response>>

pub async fn call<O: OperationDeclaration>( &self, request: O, ) -> Result<Response<O::Response>>

impl Context<'_>

pub fn upload<O: OperationDeclaration>( &self, request: O, settings: StreamSettings, ) -> Result<Upload<O>>

pub fn download<O: OperationDeclaration>( &self, request: O, settings: StreamSettings, ) -> Result<Download<O>>

pub fn exchange<O: OperationDeclaration>( &self, request: O, input: StreamSettings, output: StreamSettings, ) -> Result<Exchange<O>>

impl Context<'_>

pub fn submit_encoded( &self, operation: &str, payload: Vec<u8>, ) -> Result<EncodedInvocation>

pub async fn call_encoded( &self, operation: &str, payload: Vec<u8>, ) -> Result<Vec<u8>>

Trait Implementations

impl<'a> Clone for Context<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Host for Context<'_>

type Error = Error

type Instance<O: OperationDeclaration> = OperationInstance<O>

fn context(&self) -> &CallContext

fn with_value<T: ContextValue>(&self, value: T) -> Result<Self, ContextError>

fn submit<O: OperationDeclaration>( &self, request: O, ) -> impl Future<Output = Result<OperationInstance<O>>> + Send

fn call<O: OperationDeclaration>( &self, request: O, ) -> impl Future<Output = Result<Response<O::Response>>> + Send

fn submit_with_resources<O: OperationDeclaration<Response = ()>, R: Send + Sync + 'static>( &self, _: O, resources: Arc<R>, ) -> impl Future<Output = Result<OperationInstance<O>>> + Send

fn publish_on<S>( &self, row: &<S as StreamSpec>::Row, ) -> impl Future<Output = Result<(), Self::Error>> + Send

where S: StreamSpec, <S as StreamSpec>::Row: Message,

fn publish<S>( &self, row: &S, ) -> impl Future<Output = Result<(), Self::Error>> + Send

where S: StreamSpec<Row = S> + Message,