Struct OperationInstance 

pub struct OperationInstance<O: OperationDeclaration> { /* private fields */ }

Implementations

impl<O: OperationDeclaration> OperationInstance<O>

pub fn id(&self) -> OperationInstanceId

pub fn generation(&self) -> OperationGeneration

pub fn cancel(&self)

pub fn status(&self) -> OperationStatus

pub fn subscribe(&self) -> Receiver<OperationStatus>

pub async fn ready(&self) -> Result<()>

pub async fn join(self) -> Result<Response<O::Response>>

pub async fn cancel_and_join(self) -> Result<Response<O::Response>>

pub fn detach(self) -> OperationInstanceId

pub async fn release(self) -> Result<()>

pub async fn settle(&self) -> Result<()>

Trait Implementations

impl<O: OperationDeclaration> Drop for OperationInstance<O>

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.

impl<O: OperationDeclaration> Future for OperationInstance<O>

type Output = Result<Response<<O as OperationDeclaration>::Response>, Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut TaskContext<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<O> Instance<O> for OperationInstance<O>

where O: OperationDeclaration,

type Error = Error

fn id(&self) -> OperationInstanceId

fn status(&self) -> impl Future<Output = Result<Status>> + Send

fn cancel(&self) -> impl Future<Output = Result<()>> + Send

fn join(self) -> impl Future<Output = Result<Response<O::Response>>> + Send

fn detach(self) -> OperationInstanceId

fn cancel_and_join( self, ) -> impl Future<Output = Result<Response<<O as OperationDeclaration>::Response>, Self::Error>> + Send