Struct ContinuousQuery 

pub struct ContinuousQuery<'w, 's, Request, Response, Streams = ()>
where
    Request: 'static + Send + Sync,
    Response: 'static + Send + Sync,
    Streams: StreamPack,
{ /* private fields */ }

Implementations

impl<'w, 's, Request, Response, Streams> ContinuousQuery<'w, 's, Request, Response, Streams>

where Request: 'static + Send + Sync, Response: 'static + Send + Sync, Streams: StreamPack,

pub fn view<'a>( &'a self, key: &ContinuousServiceKey<Request, Response, Streams>, ) -> Option<ContinuousQueueView<'a, Request, Response>>

pub fn get_mut<'a>( &'a mut self, key: &ContinuousServiceKey<Request, Response, Streams>, ) -> Option<ContinuousQueueMut<'w, 's, 'a, Request, Response, Streams>>

Trait Implementations

impl<'w, 's, Request, Response, Streams> Drop for ContinuousQuery<'w, 's, Request, Response, Streams>

where Request: 'static + Send + Sync, Response: 'static + Send + Sync, Streams: StreamPack,

fn drop(&mut self)

Executes the destructor for this type.

impl<Request, Response, Streams> SystemParam for ContinuousQuery<'_, '_, Request, Response, Streams>

where Request: 'static + Send + Sync, Response: 'static + Send + Sync, Streams: StreamPack,

type State = FetchState<Request, Response, Streams>

Used to store data which persists across invocations of a system.

type Item<'w, 's> = ContinuousQuery<'w, 's, Request, Response, Streams>

The item type returned when constructing this system param. The value of this associated type should be Self, instantiated with new lifetimes.

fn init_state(world: &mut World, system_meta: &mut SystemMeta) -> Self::State

Registers any World access used by this SystemParam and creates a new instance of this param’s State.

unsafe fn new_archetype( state: &mut Self::State, archetype: &Archetype, system_meta: &mut SystemMeta, )

For the specified Archetype, registers the components accessed by this SystemParam (if applicable).a

fn apply(state: &mut Self::State, system_meta: &SystemMeta, world: &mut World)

Applies any deferred mutations stored in this SystemParam’s state. This is used to apply Commands during ApplyDeferred.

fn queue( state: &mut Self::State, system_meta: &SystemMeta, world: DeferredWorld<'_>, )

Queues any deferred mutations to be applied at the next ApplyDeferred.

unsafe fn validate_param<'w, 's>( state: &'s Self::State, _system_meta: &SystemMeta, _world: UnsafeWorldCell<'w>, ) -> Result<(), SystemParamValidationError>

Validates that the param can be acquired by the get_param.

unsafe fn get_param<'w, 's>( state: &'s mut Self::State, system_meta: &SystemMeta, world: UnsafeWorldCell<'w>, change_tick: Tick, ) -> Self::Item<'w, 's>

Creates a parameter to be passed into a SystemParamFunction.

impl<'w, 's, Request, Response, Streams> ReadOnlySystemParam for ContinuousQuery<'w, 's, Request, Response, Streams>

where Request: 'static + Send + Sync, Response: 'static + Send + Sync, Streams: StreamPack, Query<'w, 's, &'static ContinuousQueueStorage<Request>>: ReadOnlySystemParam, Query<'w, 's, Option<&'static StreamTargetMap>>: ReadOnlySystemParam, Local<'s, HashMap<Entity, DeliveredQueue<Response>>>: ReadOnlySystemParam, Commands<'w, 's>: ReadOnlySystemParam, PhantomData<fn(Streams)>: ReadOnlySystemParam,