Struct PromiseMapExecutor 

pub struct PromiseMapExecutor { /* private fields */ }

PromiseMapExecutor handles .map() operations and promise pipelining

Implementations

impl PromiseMapExecutor

pub fn new() -> Self

pub async fn register_map( &self, source_promise: PromiseId, map_function: ILExpression, result_promise: PromiseId, ) -> Result<(), RpcError>

Register a .map() operation on a promise

pub async fn register_pipelined_call( &self, target_promise: PromiseId, method: String, args: Vec<Value>, result_promise: PromiseId, call_id: CallId, ) -> Result<(), RpcError>

Register a pipelined method call on a promise

pub async fn execute_map_on_resolution( &self, promise_id: PromiseId, resolved_value: Value, ) -> Vec<(PromiseId, Result<Value, RpcError>)>

Execute map operations when a promise resolves

pub async fn execute_pipelined_calls( &self, promise_id: PromiseId, capability: Arc<dyn RpcTarget>, ) -> Vec<(CallId, PromiseId, Result<Value, RpcError>)>

Execute pipelined calls when a promise resolves to a capability

pub async fn get_dependent_promises( &self, promise_id: PromiseId, ) -> Vec<PromiseId>

Get all promises that depend on a given promise

pub async fn would_create_cycle( &self, promise: PromiseId, depends_on: PromiseId, ) -> bool

Check if there would be a cycle when adding a dependency

Trait Implementations

impl Default for PromiseMapExecutor

fn default() -> Self

Returns the “default value” for a type.