Struct PkPollable

pub struct PkPollable { /* private fields */ }

A simple implementation of Pollable based on multi-thread.

This is like Promise in JavaScript.

Implementations

impl PkPollable

pub fn execute<T>(function: T) -> Pin<Box<Self>>

where T: FnOnce(Box<dyn FnOnce(Vec<u8>) + Send + 'static>) + Send + 'static,

Creates a new PkPollable and executes a function in a new thread.

The provided function function will be executed in a separate thread. It receives a resolve closure as an argument. The user’s function should call this resolve closure with the result data (Vec<u8>) when the asynchronous operation is complete.

Arguments

• function: A closure that takes a resolve closure and performs the asynchronous task. The resolve closure should be called with the result data when the task finishes successfully.

Returns

A new PkPollable instance that can be polled to check the status of the asynchronous operation.

Trait Implementations

impl Clone for PkPollable

fn clone(&self) -> PkPollable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Pollable for PkPollable

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