Struct wlambda::threads::Sender

pub struct Sender { /* fields omitted */ }

The Sender sends RPC calls to the Receiver thread. Any values passed by WLambda code are serialized into msgpack internally and transmitted to the thread in String form. This means, your values must not be cyclic or contain non serializable data like external handles.

The Sender also provides a method for storing a sending function in the global variables for the EvalContext.

 let mut ctx = wlambda::compiler::EvalContext::new_default();

 let mut msg_handle = wlambda::threads::MsgHandle::new();
 let sender = msg_handle.sender();

 // You may register on multiple threads, but only one thread can use it at a time.
 sender.register_on_as(&mut ctx, "worker");

 // start thread here...

Methods

impl Sender

pub fn register_on_as(&self, ctx: &mut EvalContext, variable_name: &str)

Registers a call and message sending function on the supplied EvalContext. You can call this function with the global variable name of the thread function you want to call and additional arguments to that function.

let mut ctx = wlambda::compiler::EvalContext::new_default();

let mut msg_handle = wlambda::threads::MsgHandle::new();
let sender = msg_handle.sender();

sender.register_on_as(&mut ctx, "worker");

ctx.eval("worker_call :displayln \"hello world from worker thread!\";").unwrap();

// _send will not wait for the call to be finished or even started.
ctx.eval("worker_send :displayln \"hello world from worker thread!\";").unwrap();

pub fn call(&self, var_name: &str, args: VVal) -> VVal

Calls the global variable in the receiver thread with the given argument vector. You can pass none value as args too.

pub fn send(&self, var_name: &str, args: VVal)

With send you can asynchronously send messages in form of method calls to the receiver. The Receiver will process all received messages per step(). Multiple senders can send messages, while multiple Receivers can process them.

Trait Implementations

impl Clone for Sender

fn clone(&self) -> Sender

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Sender

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.