Struct VcStorage

pub struct VcStorage { /* private fields */ }

Implementations

impl VcStorage

pub fn with<T>(f: impl Future<Output = T>) -> impl Future<Output = T>

Trait Implementations

impl Default for VcStorage

fn default() -> VcStorage

Returns the “default value” for a type.

impl TurboTasksApi for VcStorage

fn subscribe_to_compilation_events( &self, _event_types: Option<Vec<String>>, ) -> Receiver<Arc<dyn CompilationEvent>>

Should not be called on the testing VcStorage. These methods are only implemented for structs with access to a MessageQueue like TurboTasks.

fn send_compilation_event(&self, _event: Arc<dyn CompilationEvent>)

Should not be called on the testing VcStorage. These methods are only implemented for structs with access to a MessageQueue like TurboTasks.

fn pin(&self) -> Arc<dyn TurboTasksApi>

fn invalidate(&self, _task: TaskId)

fn invalidate_with_reason( &self, _task: TaskId, _reason: StaticOrArc<dyn InvalidationReason>, )

fn invalidate_serialization(&self, _task: TaskId)

fn notify_scheduled_tasks(&self)

Eagerly notifies all tasks that were scheduled for notifications via schedule_notify_tasks_set()

fn try_read_task_output( &self, id: TaskId, _consistency: ReadConsistency, ) -> Result<Result<RawVc, EventListener>>

fn try_read_task_output_untracked( &self, task: TaskId, consistency: ReadConsistency, ) -> Result<Result<RawVc, EventListener>>

INVALIDATION: Be careful with this, it will not track dependencies, so using it could break cache invalidation.

fn try_read_task_cell( &self, task: TaskId, index: CellId, _options: ReadCellOptions, ) -> Result<Result<TypedCellContent, EventListener>>

fn try_read_task_cell_untracked( &self, task: TaskId, index: CellId, _options: ReadCellOptions, ) -> Result<Result<TypedCellContent, EventListener>>

INVALIDATION: Be careful with this, it will not track dependencies, so using it could break cache invalidation.

fn try_read_own_task_cell_untracked( &self, current_task: TaskId, index: CellId, options: ReadCellOptions, ) -> Result<TypedCellContent>

INVALIDATION: Be careful with this, it will not track dependencies, so using it could break cache invalidation.

fn try_read_local_output( &self, _execution_id: ExecutionId, _local_task_id: LocalTaskId, ) -> Result<Result<RawVc, EventListener>>

Reads a [RawVc::LocalOutput]. If the task has completed, returns the [RawVc] the local task points to.

fn emit_collectible(&self, _trait_type: TraitTypeId, _collectible: RawVc)

fn unemit_collectible( &self, _trait_type: TraitTypeId, _collectible: RawVc, _count: u32, )

fn unemit_collectibles( &self, _trait_type: TraitTypeId, _collectibles: &TaskCollectiblesMap, )

fn read_task_collectibles( &self, _task: TaskId, _trait_id: TraitTypeId, ) -> TaskCollectiblesMap

fn read_own_task_cell( &self, task: TaskId, index: CellId, _options: ReadCellOptions, ) -> Result<TypedCellContent>

fn update_own_task_cell( &self, task: TaskId, index: CellId, content: CellContent, )

fn connect_task(&self, _task: TaskId)

fn mark_own_task_as_finished(&self, _task: TaskId)

fn mark_own_task_as_session_dependent(&self, _task: TaskId)

fn set_own_task_aggregation_number( &self, _task: TaskId, _aggregation_number: u32, )

fn detached_for_testing( &self, _f: Pin<Box<dyn Future<Output = Result<()>> + Send + 'static>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'static>>

Wraps the given future in the current task.

fn task_statistics(&self) -> &TaskStatisticsApi

fn stop_and_wait(&self) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>

impl TurboTasksCallApi for VcStorage

fn dynamic_call( &self, func: FunctionId, this: Option<RawVc>, arg: Box<dyn MagicAny>, _persistence: TaskPersistence, ) -> RawVc

Calls a native function with arguments. Resolves arguments when needed with a wrapper task.

fn native_call( &self, _func: FunctionId, _this: Option<RawVc>, _arg: Box<dyn MagicAny>, _persistence: TaskPersistence, ) -> RawVc

Call a native function with arguments. All inputs must be resolved.

fn trait_call( &self, _trait_type: TraitTypeId, _trait_fn_name: Cow<'static, str>, _this: RawVc, _arg: Box<dyn MagicAny>, _persistence: TaskPersistence, ) -> RawVc

Calls a trait method with arguments. First input is the self object. Uses a wrapper task to resolve

fn run_once( &self, _future: Pin<Box<dyn Future<Output = Result<()>> + Send + 'static>>, ) -> TaskId

fn run_once_with_reason( &self, _reason: StaticOrArc<dyn InvalidationReason>, _future: Pin<Box<dyn Future<Output = Result<()>> + Send + 'static>>, ) -> TaskId

fn run_once_process( &self, _future: Pin<Box<dyn Future<Output = Result<()>> + Send + 'static>>, ) -> TaskId