Struct WorkerGenLevelSource

pub struct WorkerGenLevelSource { /* private fields */ }

A wrapper for LevelGenerator that implements LevelSource to provide asynchronous level generation. This wrapper dispatches incoming chunk request into the given number of worker threads.

Implementations

impl WorkerGenLevelSource

pub fn new<B>(generator_builder: B, workers_count: usize) -> Self

where B: LevelGeneratorBuilder + Send + Sync + 'static,

Trait Implementations

impl LevelSource for WorkerGenLevelSource

fn request_chunk_load( &mut self, req: ChunkLoadRequest, ) -> Result<(), (LevelSourceError, ChunkLoadRequest)>

Request loading of the chunk at the given position. If you return an error, you must return back the given ChunkInfo together with the LevelSourceError. If you return Ok(()) you must give a result later when calling poll_chunk. This operation must be non-blocking.

fn poll_chunk( &mut self, ) -> Option<Result<ProtoChunk, (LevelSourceError, ChunkLoadRequest)>>

Poll the next loaded chunk that is ready to be inserted into the level’s chunk storage. Every requested load chunk request_chunk_load method that returned Ok(()) should return some some result here, even if it’s an error. This operation must be non-blocking.

fn request_chunk_save( &mut self, req: ChunkSaveRequest, ) -> Result<(), LevelSourceError>

Request saving of the chunk at the given position. This operation must be non-blocking.