Struct SimpleExecutor

pub struct SimpleExecutor<EL: ErrorListener, TP: BaseThreadPool, AR: BaseAsyncRuntime> { /* private fields */ }

The default executor used. It creates an internal thread pool, and each call to a Rust function is handled by a different thread.

Implementations

impl<EL: ErrorListener, TP: BaseThreadPool, AR: BaseAsyncRuntime> SimpleExecutor<EL, TP, AR>

pub fn new(error_listener: EL, thread_pool: TP, async_runtime: AR) -> Self

Create a new executor backed by a thread pool.

pub fn thread_pool(&self) -> &TP

pub fn async_runtime(&self) -> &AR

Trait Implementations

impl<EL: ErrorListener + Sync, TP: BaseThreadPool, AR: BaseAsyncRuntime> Executor for SimpleExecutor<EL, TP, AR>

fn execute_normal<Rust2DartCodec, TaskFn>( &self, task_info: TaskInfo, task: TaskFn, )

where TaskFn: FnOnce(TaskContext) -> Result<Rust2DartCodec::Message, Rust2DartCodec::Message> + Send + 'static, Rust2DartCodec: BaseCodec,

Executes a Rust function and transforms its return value into a Dart-compatible value, i.e. types that implement [IntoDart].

fn execute_sync<Rust2DartCodec, SyncTaskFn>( &self, _task_info: TaskInfo, sync_task: SyncTaskFn, ) -> Rust2DartCodec::Message

where SyncTaskFn: FnOnce() -> Result<Rust2DartCodec::Message, Rust2DartCodec::Message>, Rust2DartCodec: BaseCodec,

Executes a synchronous Rust function

fn execute_async<Rust2DartCodec, TaskFn, TaskRetFut>( &self, task_info: TaskInfo, task: TaskFn, )

where TaskFn: FnOnce(TaskContext) -> TaskRetFut + Send + 'static, TaskRetFut: Future<Output = Result<Rust2DartCodec::Message, Rust2DartCodec::Message>> + TaskRetFutTrait, Rust2DartCodec: BaseCodec,