README
T
AssetEntry
- ::equalAssetPriority::equal
- ::not_equalAssetPriority::not_equal
- ::outputAssetPriority::output
- ::to_reprAssetPriority::to_repr
- ::to_stringAssetPriority::to_string
- ::cancelAssetStreamManager::cancel
- ::enqueueAssetStreamManager::enqueue
- ::image_fetch_fnAssetStreamManager::image_fetch_fn
- ::newAssetStreamManager::new
- ::progressAssetStreamManager::progress
- ::reprioritizeAssetStreamManager::reprioritize
- ::updateAssetStreamManager::update
- ::evictAssetStreamer::evict
- ::newAssetStreamer::new
- ::progressAssetStreamer::progress
- ::requestAssetStreamer::request
- ::request_by_distanceAssetStreamer::request_by_distance
- ::request_lodAssetStreamer::request_lod
- ::stream_managerAssetStreamer::stream_manager
- ::touchAssetStreamer::touch
- ::updateAssetStreamer::update
- ::defaultAssetStreamerConfig::default
- ::outputAssetStreamerConfig::output
- ::to_reprAssetStreamerConfig::to_repr
- ::to_stringAssetStreamerConfig::to_string
- ::commit_imageAsyncImageLoader::commit_image
- ::drain_completedAsyncImageLoader::drain_completed
- ::enqueueAsyncImageLoader::enqueue
- ::newAsyncImageLoader::new
- ::progressAsyncImageLoader::progress
- ::requestAsyncImageLoader::request
- ::start_pendingAsyncImageLoader::start_pending
- ::outputAsyncImageProgress::output
- ::to_reprAsyncImageProgress::to_repr
- ::to_stringAsyncImageProgress::to_string
- ::outputAsyncImageRequest::output
- ::to_reprAsyncImageRequest::to_repr
- ::to_stringAsyncImageRequest::to_string
- ::outputAsyncImageStatus::output
- ::to_intAsyncImageStatus::to_int
- ::to_reprAsyncImageStatus::to_repr
- ::to_stringAsyncImageStatus::to_string
- ::defaultDistanceThresholds::default
- ::outputDistanceThresholds::output
- ::to_reprDistanceThresholds::to_repr
- ::to_stringDistanceThresholds::to_string
- ::outputStreamProgress::output
- ::to_reprStreamProgress::to_repr
- ::to_stringStreamProgress::to_string
T
StreamRequest

kagura_asset_loader

Async image/asset streaming and priority-queued loading for Kagura, on top of mizchi/atlas + mizchi/gfx (extracted from kagura_engine)

Download zip

Author

mizchi

Version

0.6.0

License

Apache-2.0

Repository

github.com/mizchi/kagura

Last updated

15 days ago

Downloads

Dependencies

mizchi/kagura_asset_loader does not have a README file

AssetEntry

source

type AssetEntry

AssetPriority

source

pub enum AssetPriority {
  Critical
  High
  Normal
  Low
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

impl Show for AssetPriority

AssetPriority::equal

source

fn AssetPriority::equal(AssetPriority, AssetPriority) -> Bool

AssetPriority::not_equal

source

fn AssetPriority::not_equal(x : AssetPriority, y : AssetPriority) -> Bool

AssetPriority::output

source

fn AssetPriority::output(self : AssetPriority, logger : &Logger) -> Unit

AssetPriority::to_repr

source

fn AssetPriority::to_repr(AssetPriority) -> @moonbitlang/core/debug.Repr
Repr

AssetPriority::to_string

source

fn AssetPriority::to_string(self : AssetPriority) -> String

AssetStreamManager

source

pub struct AssetStreamManager {
  fetcher : &@mizchi/kagura_platform/fetch.BytesFetcher
BytesFetcher
  max_concurrent : Int
  next_id : Int
  pending : Array[StreamRequest]
  active : Map[Int, StreamRequest]
  completed_count : Int
  failed_count : Int
}

AssetStreamManager::cancel

source

fn AssetStreamManager::cancel(self : AssetStreamManager, id : Int) -> Unit

AssetStreamManager::enqueue

source

fn AssetStreamManager::enqueue(self : AssetStreamManager, url : String, priority : AssetPriority, on_complete : (Bytes?) -> Unit) -> Int

AssetStreamManager::image_fetch_fn

source

fn AssetStreamManager::image_fetch_fn(self : AssetStreamManager, priority? : AssetPriority) -> ((String, (@mizchi/atlas.ImageSpec
ImageSpec?) -> Unit) -> Unit)

Creates an AsyncImageLoader-compatible fetch_image_fn from this stream manager.

AssetStreamManager::new

source

fn AssetStreamManager::new(fetcher : &@mizchi/kagura_platform/fetch.BytesFetcher
BytesFetcher, max_concurrent? : Int) -> AssetStreamManager

AssetStreamManager::progress

source

fn AssetStreamManager::progress(self : AssetStreamManager) -> StreamProgress

AssetStreamManager::reprioritize

source

fn AssetStreamManager::reprioritize(self : AssetStreamManager, id : Int, new_priority : AssetPriority) -> Bool

AssetStreamManager::update

source

fn AssetStreamManager::update(self : AssetStreamManager) -> Unit

AssetStreamer

source

pub struct AssetStreamer {
  manager : AssetStreamManager
  config : AssetStreamerConfig
  frame_count : Int
  handles : Map[String, AssetEntry]
  on_evict : (@mizchi/atlas.AssetKey
AssetKey) -> Unit
}

AssetStreamer::evict

source

fn AssetStreamer::evict(self : AssetStreamer, key : @mizchi/atlas.AssetKey
AssetKey) -> Unit

AssetStreamer::new

source

fn AssetStreamer::new(fetcher : &@mizchi/kagura_platform/fetch.BytesFetcher
BytesFetcher, config? : AssetStreamerConfig, on_evict? : (@mizchi/atlas.AssetKey
AssetKey) -> Unit) -> AssetStreamer

AssetStreamer::progress

source

fn AssetStreamer::progress(self : AssetStreamer) -> StreamProgress

AssetStreamer::request

source

fn AssetStreamer::request(self : AssetStreamer, url : String, key : @mizchi/atlas.AssetKey
AssetKey, priority : AssetPriority, on_complete : (Bytes?) -> Unit) -> Int

AssetStreamer::request_by_distance

source

fn AssetStreamer::request_by_distance(self : AssetStreamer, url : String, key : @mizchi/atlas.AssetKey
AssetKey, distance : Double, thresholds? : DistanceThresholds, on_complete~ : (Bytes?) -> Unit) -> Int

AssetStreamer::request_lod

source

fn AssetStreamer::request_lod(self : AssetStreamer, url : String, key : @mizchi/atlas.AssetKey
AssetKey, lod_level : Int, priority : AssetPriority, on_complete : (Bytes?) -> Unit) -> Int

AssetStreamer::stream_manager

source

fn AssetStreamer::stream_manager(self : AssetStreamer) -> AssetStreamManager

AssetStreamer::touch

source

fn AssetStreamer::touch(self : AssetStreamer, key : @mizchi/atlas.AssetKey
AssetKey) -> Unit

AssetStreamer::update

source

fn AssetStreamer::update(self : AssetStreamer) -> Unit

AssetStreamerConfig

source

pub(all) struct AssetStreamerConfig {
  max_concurrent : Int
  max_cached : Int
  eviction_interval : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for AssetStreamerConfig

AssetStreamerConfig::default

source

fn AssetStreamerConfig::default() -> AssetStreamerConfig

AssetStreamerConfig::output

source

fn AssetStreamerConfig::output(self : AssetStreamerConfig, logger : &Logger) -> Unit

AssetStreamerConfig::to_repr

source

fn AssetStreamerConfig::to_repr(AssetStreamerConfig) -> @moonbitlang/core/debug.Repr
Repr

AssetStreamerConfig::to_string

source

fn AssetStreamerConfig::to_string(self : AssetStreamerConfig) -> String

AsyncImageLoader

source

pub struct AsyncImageLoader {
  next_id : Int
  requests : Map[Int, AsyncImageRequest]
  pending_ids : Array[Int]
  completed_ids : Array[Int]
  fetch_image_fn : (String, (@mizchi/atlas.ImageSpec
ImageSpec?) -> Unit) -> Unit
}

AsyncImageLoader::commit_image

source

fn AsyncImageLoader::commit_image(self : AsyncImageLoader, id : Int, repo : @mizchi/atlas.SimpleImageRepository
SimpleImageRepository) -> @mizchi/gfx.ImageHandle
ImageHandle?

AsyncImageLoader::drain_completed

source

fn AsyncImageLoader::drain_completed(self : AsyncImageLoader) -> Array[Int]

AsyncImageLoader::enqueue

source

fn AsyncImageLoader::enqueue(self : AsyncImageLoader, key : @mizchi/atlas.AssetKey
AssetKey, url : String) -> Int

AsyncImageLoader::new

source

fn AsyncImageLoader::new(fetch_image_fn? : (String, (@mizchi/atlas.ImageSpec
ImageSpec?) -> Unit) -> Unit) -> AsyncImageLoader

AsyncImageLoader::progress

source

fn AsyncImageLoader::progress(self : AsyncImageLoader) -> AsyncImageProgress

AsyncImageLoader::request

source

fn AsyncImageLoader::request(self : AsyncImageLoader, id : Int) -> AsyncImageRequest?

AsyncImageLoader::start_pending

source

fn AsyncImageLoader::start_pending(self : AsyncImageLoader) -> Int

AsyncImageProgress

source

pub struct AsyncImageProgress {
  total : Int
  pending : Int
  loading : Int
  succeeded : Int
  failed : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for AsyncImageProgress

AsyncImageProgress::output

source

fn AsyncImageProgress::output(self : AsyncImageProgress, logger : &Logger) -> Unit

AsyncImageProgress::to_repr

source

fn AsyncImageProgress::to_repr(AsyncImageProgress) -> @moonbitlang/core/debug.Repr
Repr

AsyncImageProgress::to_string

source

fn AsyncImageProgress::to_string(self : AsyncImageProgress) -> String

AsyncImageRequest

source

pub struct AsyncImageRequest {
  id : Int
  key : @mizchi/atlas.AssetKey
AssetKey
  url : String
  status : AsyncImageStatus
  image_spec : @mizchi/atlas.ImageSpec
ImageSpec?
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for AsyncImageRequest

AsyncImageRequest::output

source

fn AsyncImageRequest::output(self : AsyncImageRequest, logger : &Logger) -> Unit

AsyncImageRequest::to_repr

source

fn AsyncImageRequest::to_repr(AsyncImageRequest) -> @moonbitlang/core/debug.Repr
Repr

AsyncImageRequest::to_string

source

fn AsyncImageRequest::to_string(self : AsyncImageRequest) -> String

AsyncImageStatus

source

pub enum AsyncImageStatus {
  Pending
  Loading
  Succeeded
  Failed
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for AsyncImageStatus

AsyncImageStatus::output

source

fn AsyncImageStatus::output(self : AsyncImageStatus, logger : &Logger) -> Unit

AsyncImageStatus::to_int

source

fn AsyncImageStatus::to_int(self : AsyncImageStatus) -> Int

AsyncImageStatus::to_repr

source

fn AsyncImageStatus::to_repr(AsyncImageStatus) -> @moonbitlang/core/debug.Repr
Repr

AsyncImageStatus::to_string

source

fn AsyncImageStatus::to_string(self : AsyncImageStatus) -> String

DistanceThresholds

source

pub(all) struct DistanceThresholds {
  critical : Double
  high : Double
  normal : Double
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for DistanceThresholds

DistanceThresholds::default

source

fn DistanceThresholds::default() -> DistanceThresholds

DistanceThresholds::output

source

fn DistanceThresholds::output(self : DistanceThresholds, logger : &Logger) -> Unit

DistanceThresholds::to_repr

source

fn DistanceThresholds::to_repr(DistanceThresholds) -> @moonbitlang/core/debug.Repr
Repr

DistanceThresholds::to_string

source

fn DistanceThresholds::to_string(self : DistanceThresholds) -> String

StreamProgress

source

pub(all) struct StreamProgress {
  total : Int
  pending : Int
  active : Int
  completed : Int
  failed : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for StreamProgress

StreamProgress::output

source

fn StreamProgress::output(self : StreamProgress, logger : &Logger) -> Unit

StreamProgress::to_repr

source

fn StreamProgress::to_repr(StreamProgress) -> @moonbitlang/core/debug.Repr
Repr

StreamProgress::to_string

source

fn StreamProgress::to_string(self : StreamProgress) -> String

StreamRequest

source

type StreamRequest

Source Files

Site source Report issue Packages Build queue Skills Statistics

kagura_asset_loader

#AssetEntry

#AssetPriority

#AssetPriority::equal

#AssetPriority::not_equal

#AssetPriority::output

#AssetPriority::to_repr

#AssetPriority::to_string

#AssetStreamManager

#AssetStreamManager::cancel

#AssetStreamManager::enqueue

#AssetStreamManager::image_fetch_fn

#AssetStreamManager::new

#AssetStreamManager::progress

#AssetStreamManager::reprioritize

#AssetStreamManager::update

#AssetStreamer

#AssetStreamer::evict

#AssetStreamer::new

#AssetStreamer::progress

#AssetStreamer::request

#AssetStreamer::request_by_distance

#AssetStreamer::request_lod

#AssetStreamer::stream_manager

#AssetStreamer::touch

#AssetStreamer::update

#AssetStreamerConfig

#AssetStreamerConfig::default

#AssetStreamerConfig::output

#AssetStreamerConfig::to_repr

#AssetStreamerConfig::to_string

#AsyncImageLoader

#AsyncImageLoader::commit_image

#AsyncImageLoader::drain_completed

#AsyncImageLoader::enqueue

#AsyncImageLoader::new

#AsyncImageLoader::progress

#AsyncImageLoader::request

#AsyncImageLoader::start_pending

#AsyncImageProgress

#AsyncImageProgress::output

#AsyncImageProgress::to_repr

#AsyncImageProgress::to_string

#AsyncImageRequest

#AsyncImageRequest::output

#AsyncImageRequest::to_repr

#AsyncImageRequest::to_string

#AsyncImageStatus

#AsyncImageStatus::output

#AsyncImageStatus::to_int

#AsyncImageStatus::to_repr

#AsyncImageStatus::to_string

#DistanceThresholds

#DistanceThresholds::default

#DistanceThresholds::output

#DistanceThresholds::to_repr

#DistanceThresholds::to_string

#StreamProgress

#StreamProgress::output

#StreamProgress::to_repr

#StreamProgress::to_string

#StreamRequest

Source Files

AssetEntry

AssetPriority

AssetPriority::equal

AssetPriority::not_equal

AssetPriority::output

AssetPriority::to_repr

AssetPriority::to_string

AssetStreamManager

AssetStreamManager::cancel

AssetStreamManager::enqueue

AssetStreamManager::image_fetch_fn

AssetStreamManager::new

AssetStreamManager::progress

AssetStreamManager::reprioritize

AssetStreamManager::update

AssetStreamer

AssetStreamer::evict

AssetStreamer::new

AssetStreamer::progress

AssetStreamer::request

AssetStreamer::request_by_distance

AssetStreamer::request_lod

AssetStreamer::stream_manager

AssetStreamer::touch

AssetStreamer::update

AssetStreamerConfig

AssetStreamerConfig::default

AssetStreamerConfig::output

AssetStreamerConfig::to_repr

AssetStreamerConfig::to_string

AsyncImageLoader

AsyncImageLoader::commit_image

AsyncImageLoader::drain_completed

AsyncImageLoader::enqueue

AsyncImageLoader::new

AsyncImageLoader::progress

AsyncImageLoader::request

AsyncImageLoader::start_pending

AsyncImageProgress

AsyncImageProgress::output

AsyncImageProgress::to_repr

AsyncImageProgress::to_string

AsyncImageRequest

AsyncImageRequest::output

AsyncImageRequest::to_repr

AsyncImageRequest::to_string

AsyncImageStatus

AsyncImageStatus::output

AsyncImageStatus::to_int

AsyncImageStatus::to_repr

AsyncImageStatus::to_string

DistanceThresholds

DistanceThresholds::default

DistanceThresholds::output

DistanceThresholds::to_repr

DistanceThresholds::to_string

StreamProgress

StreamProgress::output

StreamProgress::to_repr

StreamProgress::to_string

StreamRequest