Update for Bevy 0.15

Author: mockersf

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bevy_embedded_assets"
-version = "0.11.0"
+version = "0.12.0-rc.1"
 authors = ["François Mockers <[email protected]>"]
 edition = "2021"
 license = "MIT OR Apache-2.0"
@@ -18,7 +18,7 @@ default = ["default-source"]
 default-source = ["futures-io", "futures-lite"]
 
 [dependencies.bevy]
-version = "0.14.0"
+version = "0.15.0-rc.3"
 default-features = false
 features = ["bevy_asset"]
 

README.md

@@ -28,6 +28,7 @@ fn main() {
 |Bevy|bevy_embedded_assets|
 |---|---|
 |main|main|
+|0.15|0.12|
 |0.14|0.11|
 |0.13|0.10|
 |0.12|0.9|

src/asset_reader.rs

@@ -6,7 +6,9 @@ use std::{
 };
 
 use bevy::{
-    asset::io::{AssetReader, AssetReaderError, ErasedAssetReader, PathStream, Reader},
+    asset::io::{
+        AssetReader, AssetReaderError, AsyncSeekForward, ErasedAssetReader, PathStream, Reader,
+    },
     utils::HashMap,
 };
 use futures_io::{AsyncRead, AsyncSeek};
@@ -147,6 +149,20 @@ impl EmbeddedAssetReader {
 #[derive(Default, Debug, Clone, Copy)]
 pub struct DataReader(pub &'static [u8]);
 
+impl Reader for DataReader {
+    fn read_to_end<'a>(
+        &'a mut self,
+        buf: &'a mut Vec<u8>,
+    ) -> bevy::asset::io::StackFuture<
+        'a,
+        std::io::Result<usize>,
+        { bevy::asset::io::STACK_FUTURE_SIZE },
+    > {
+        let future = futures_lite::AsyncReadExt::read_to_end(self, buf);
+        bevy::asset::io::StackFuture::from(future)
+    }
+}
+
 impl AsyncRead for DataReader {
     fn poll_read(
         self: Pin<&mut Self>,
@@ -171,6 +187,19 @@ impl AsyncSeek for DataReader {
     }
 }
 
+impl AsyncSeekForward for DataReader {
+    fn poll_seek_forward(
+        self: Pin<&mut Self>,
+        _: &mut std::task::Context<'_>,
+        _offset: u64,
+    ) -> Poll<futures_io::Result<u64>> {
+        Poll::Ready(Err(futures_io::Error::new(
+            futures_io::ErrorKind::Other,
+            EmbeddedDataReaderError::SeekNotSupported,
+        )))
+    }
+}
+
 #[derive(Error, Debug)]
 enum EmbeddedDataReaderError {
     #[error("Seek is not supported when embeded")]
@@ -203,10 +232,11 @@ pub(crate) fn get_meta_path(path: &Path) -> PathBuf {
 }
 
 impl AssetReader for EmbeddedAssetReader {
-    async fn read<'a>(&'a self, path: &'a Path) -> Result<Box<Reader<'a>>, AssetReaderError> {
+    // async fn read<'a>(&'a self, path: &'a Path) -> Result<Box<dyn Reader>, AssetReaderError> {
+    async fn read<'a>(&'a self, path: &'a Path) -> Result<impl Reader + 'a, AssetReaderError> {
         if self.has_file_sync(path) {
             self.load_path_sync(path).map(|reader| {
-                let boxed: Box<Reader> = Box::new(reader);
+                let boxed: Box<dyn Reader> = Box::new(reader);
                 boxed
             })
         } else if let Some(fallback) = self.fallback.as_ref() {
@@ -216,11 +246,11 @@ impl AssetReader for EmbeddedAssetReader {
         }
     }
 
-    async fn read_meta<'a>(&'a self, path: &'a Path) -> Result<Box<Reader<'a>>, AssetReaderError> {
+    async fn read_meta<'a>(&'a self, path: &'a Path) -> Result<impl Reader + 'a, AssetReaderError> {
         let meta_path = get_meta_path(path);
         if self.has_file_sync(&meta_path) {
             self.load_path_sync(&meta_path).map(|reader| {
-                let boxed: Box<Reader> = Box::new(reader);
+                let boxed: Box<dyn Reader> = Box::new(reader);
                 boxed
             })
         } else if let Some(fallback) = self.fallback.as_ref() {

tests/as_default.rs

@@ -2,7 +2,10 @@
 
 use std::fmt::Display;
 
-use bevy::prelude::*;
+use bevy::{
+    asset::{io::Reader, LoadContext},
+    prelude::*,
+};
 use bevy_embedded_assets::{EmbeddedAssetPlugin, PluginMode};
 use thiserror::Error;
 
@@ -27,11 +30,11 @@ impl bevy::asset::AssetLoader for TestAssetLoader {
     type Asset = TestAsset;
     type Settings = ();
     type Error = TestError;
-    async fn load<'a>(
-        &'a self,
-        reader: &'a mut bevy::asset::io::Reader<'_>,
-        _: &'a (),
-        _: &'a mut bevy::asset::LoadContext<'_>,
+    async fn load(
+        &self,
+        reader: &mut dyn Reader,
+        _: &(),
+        _: &mut LoadContext<'_>,
     ) -> Result<Self::Asset, Self::Error> {
         let mut bytes = Vec::new();
         bevy::asset::AsyncReadExt::read_to_end(reader, &mut bytes)

tests/as_default_with_fallback.rs

@@ -2,7 +2,10 @@
 
 use std::fmt::Display;
 
-use bevy::prelude::*;
+use bevy::{
+    asset::{io::Reader, LoadContext},
+    prelude::*,
+};
 use bevy_embedded_assets::{EmbeddedAssetPlugin, PluginMode};
 use thiserror::Error;
 
@@ -27,11 +30,11 @@ impl bevy::asset::AssetLoader for TestAssetLoader {
     type Asset = TestAsset;
     type Settings = ();
     type Error = TestError;
-    async fn load<'a>(
-        &'a self,
-        reader: &'a mut bevy::asset::io::Reader<'_>,
-        _: &'a (),
-        _: &'a mut bevy::asset::LoadContext<'_>,
+    async fn load(
+        &self,
+        reader: &mut dyn Reader,
+        _: &(),
+        _: &mut LoadContext<'_>,
     ) -> Result<Self::Asset, Self::Error> {
         let mut bytes = Vec::new();
         bevy::asset::AsyncReadExt::read_to_end(reader, &mut bytes)

tests/embedded.rs

@@ -1,6 +1,9 @@
 use std::fmt::Display;
 
-use bevy::prelude::*;
+use bevy::{
+    asset::{io::Reader, LoadContext},
+    prelude::*,
+};
 use bevy_embedded_assets::EmbeddedAssetPlugin;
 use thiserror::Error;
 
@@ -25,11 +28,11 @@ impl bevy::asset::AssetLoader for TestAssetLoader {
     type Asset = TestAsset;
     type Settings = ();
     type Error = TestError;
-    async fn load<'a>(
-        &'a self,
-        reader: &'a mut bevy::asset::io::Reader<'_>,
-        _: &'a (),
-        _: &'a mut bevy::asset::LoadContext<'_>,
+    async fn load(
+        &self,
+        reader: &mut dyn Reader,
+        _: &(),
+        _: &mut LoadContext<'_>,
     ) -> Result<Self::Asset, Self::Error> {
         let mut bytes = Vec::new();
         bevy::asset::AsyncReadExt::read_to_end(reader, &mut bytes)