Struct TokioFuturePollable 

pub struct TokioFuturePollable { /* private fields */ }

Available on crate features std and tokio-runtime only.

A Pollable adapter that spawns a Future onto the Tokio runtime and exposes its completion through the Pollable interface.

Example with PkHashmapMethod

use pk_command::{PkCommand, PkHashmapMethod, tokio_adapter::TokioFuturePollable};
let method_impl = Box::new(move |param: Option<Vec<u8>>| {
    TokioFuturePollable::from_future(async move {
        // do_something_with(param);
        Ok(Some(b"async result".to_vec()))
    })
});
let methods = PkHashmapMethod::new(vec![("ASYNC".to_string(), method_impl)]);

Implementations

impl TokioFuturePollable

pub fn from_future<F>(fut: F) -> Pin<Box<dyn Pollable>>

where F: Future<Output = Result<Option<Vec<u8>>, String>> + Send + 'static,

Spawn a future onto the Tokio runtime and return a Pollable that becomes ready when the future completes.

The provided Future must output Result<Option<Vec<u8>>, String>.

Trait Implementations

impl Pollable for TokioFuturePollable

fn poll(&self) -> Poll<Result<Option<Vec<u8>>, String>>

Polls the operation for completion.