pub struct Pipeline {
pub chunks: HashSet<Vec2<i32>>,
pub leftovers: HashMap<Vec2<i32>, Vec<BlockChange>>,
/* private fields */
}
Expand description
A pipeline where chunks are initialized and generated.
Fields
chunks: HashSet<Vec2<i32>>
A HashSet that keeps track of what chunks are in the pipeline.
leftovers: HashMap<Vec2<i32>, Vec<BlockChange>>
Leftover changes to chunks.
Implementations
sourceimpl Pipeline
impl Pipeline
sourcepub fn has(&self, coords: &Vec2<i32>) -> bool
pub fn has(&self, coords: &Vec2<i32>) -> bool
Check to see if a chunk is in this pipeline. Chunks are added into the pipeline
by calling pipeline.push
.
sourcepub fn len(&self) -> usize
pub fn len(&self) -> usize
Get the length of this pipeline, in other words how many stages there are.
sourcepub fn push(&mut self, coords: &Vec2<i32>, index: usize)
pub fn push(&mut self, coords: &Vec2<i32>, index: usize)
Push a chunk job into the pipeline’s queue. Does nothing if chunk is in the pipeline already. Chunks that are pushed into the pipeline will only be freed from the pipeline if they reach the end of the pipeline.
sourcepub fn pop(&mut self) -> Option<(Vec2<i32>, usize)>
pub fn pop(&mut self) -> Option<(Vec2<i32>, usize)>
Pop a chunk job from the queue. This does not remove the chunk from the pipeline.
Calling pipeline.has
will still return true as chunk hasn’t reached the last stage.
sourcepub fn postpone(&mut self, coords: &Vec2<i32>, index: usize)
pub fn postpone(&mut self, coords: &Vec2<i32>, index: usize)
Postpone the chunk process to wait for its neighbors. Similar to pipeline.push
, but
checks if chunk is already waiting in queue. Panics if true.
sourcepub fn add_stage<T>(&mut self, stage: T) where
T: 'static + ChunkStage + Send + Sync,
pub fn add_stage<T>(&mut self, stage: T) where
T: 'static + ChunkStage + Send + Sync,
Add a stage to the chunking pipeline.
sourcepub fn get_stage(&mut self, index: usize) -> &Arc<dyn ChunkStage + Send + Sync>
pub fn get_stage(&mut self, index: usize) -> &Arc<dyn ChunkStage + Send + Sync>
Get the stage instance at index.
sourcepub fn process(
&mut self,
processes: Vec<(Chunk, Option<Space>, usize)>,
registry: &Registry,
config: &WorldConfig,
noise: &SeededNoise,
terrain: &SeededTerrain
)
pub fn process(
&mut self,
processes: Vec<(Chunk, Option<Space>, usize)>,
registry: &Registry,
config: &WorldConfig,
noise: &SeededNoise,
terrain: &SeededTerrain
)
Process a list of chunk processes, generated from the ECS system PipeliningSystem
.
sourcepub fn results(&self) -> Result<(Vec<Chunk>, Vec<BlockChange>), TryRecvError>
pub fn results(&self) -> Result<(Vec<Chunk>, Vec<BlockChange>), TryRecvError>
Attempt to retrieve the results from pipeline.process
Auto Trait Implementations
impl !RefUnwindSafe for Pipeline
impl Send for Pipeline
impl Sync for Pipeline
impl Unpin for Pipeline
impl !UnwindSafe for Pipeline
Blanket Implementations
impl<T> Any for T where
T: Any,
impl<T> Any for T where
T: Any,
fn get_type_id(&self) -> TypeId
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T> Downcast for T where
T: Any,
impl<T> Downcast for T where
T: Any,
fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>
fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>
Convert Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
. Read more
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
Convert Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
. Read more
fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert &Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s. Read more
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert &mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<T> Pointable for T
impl<T> Pointable for T
impl<SS, SP> SupersetOf<SS> for SP where
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SP where
SS: SubsetOf<SP>,
fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
The inverse inclusion map: attempts to construct self
from the equivalent element of its
superset. Read more
fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
Checks if self
is actually part of its subset T
(and can be converted to it).
fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
Use with care! Same as self.to_subset
but without any property checks. Always succeeds.
fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
The inclusion map: converts self
to the equivalent element of its superset.
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more