Struct qapi::futures::QapiService

pub struct QapiService<W> { /* private fields */ }

Implementations

impl<W> QapiService<W>

pub fn execute<C: Command>( &self, command: C ) -> impl Future<Output = ExecuteResult<C>>where W: Sink<Execute<C, u32>, Error = Error> + Unpin,

pub fn guest_sync( &self, sync_value: i32 ) -> impl Future<Output = Result<(), ExecuteError>>where W: Sink<Execute<guest_sync, u32>, Error = Error> + Unpin,

Trait Implementations

impl<W> Drop for QapiService<W>

fn drop(&mut self)

Executes the destructor for this type.

impl<W, C: Command + 'static> Service<C> for QapiService<W>where W: Sink<Execute<C, u32>, Error = Error> + Unpin + Send + 'static,

type Response = <C as Command>::Ok

Responses given by the service.

type Error = ExecuteError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<QapiService<W> as Service<C>>::Response, <QapiService<W> as Service<C>>::Error>>, Global>>

The future response value.

fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: C) -> Self::Future

Process the request and return the response asynchronously.