Struct maplibre::io::apc::SchedulerAsyncProcedureCall

pub struct SchedulerAsyncProcedureCall<K: OffscreenKernel, S: Scheduler> {
    channel: (Sender<Message>, Receiver<Message>),
    buffer: RefCell<Vec<Message>>,
    scheduler: S,
    phantom_k: PhantomData<K>,
    offscreen_kernel_config: OffscreenKernelConfig,
}

Fields

channel: (Sender<Message>, Receiver<Message>)

buffer: RefCell<Vec<Message>>

scheduler: S

phantom_k: PhantomData<K>

offscreen_kernel_config: OffscreenKernelConfig

Implementations

impl<K: OffscreenKernel, S: Scheduler> SchedulerAsyncProcedureCall<K, S>

pub fn new(scheduler: S, offscreen_kernel_config: OffscreenKernelConfig) -> Self

Trait Implementations

impl<K: OffscreenKernel, S: Scheduler> AsyncProcedureCall<K> for SchedulerAsyncProcedureCall<K, S>

type Context = SchedulerContext

type ReceiveIterator<F: FnMut(&Message) -> bool> = IntoIter<Message>

fn receive<F: FnMut(&Message) -> bool>( &self, filter: F ) -> Self::ReceiveIterator<F>

Try to receive a message non-blocking.

fn call( &self, input: Input, procedure: AsyncProcedure<K, Self::Context> ) -> Result<(), CallError>

Call an AsyncProcedure using some Input. This function is non-blocking and returns immediately.