#321 Fix async examples by feature-gating Command implementations + Add pokedex example in CI so that at least one async example is runned on CI

This commit is contained in:
Olivier Pinon 2020-04-25 02:03:17 +02:00
parent 70081c9649
commit ce2ed35a1a
2 changed files with 58 additions and 0 deletions

View File

@ -29,3 +29,5 @@ jobs:
run: cargo check --package iced --target wasm32-unknown-unknown run: cargo check --package iced --target wasm32-unknown-unknown
- name: Check compilation of `tour` example - name: Check compilation of `tour` example
run: cargo build --package tour --target wasm32-unknown-unknown run: cargo build --package tour --target wasm32-unknown-unknown
- name: Check compilation of `pokedex` example
run: cargo build --package pokedex --target wasm32-unknown-unknown

View File

@ -27,6 +27,7 @@ impl<T> Command<T> {
/// Creates a [`Command`] that performs the action of the given future. /// Creates a [`Command`] that performs the action of the given future.
/// ///
/// [`Command`]: struct.Command.html /// [`Command`]: struct.Command.html
#[cfg(not(target_arch = "wasm32"))]
pub fn perform<A>( pub fn perform<A>(
future: impl Future<Output = T> + 'static + Send, future: impl Future<Output = T> + 'static + Send,
f: impl Fn(T) -> A + 'static + Send, f: impl Fn(T) -> A + 'static + Send,
@ -36,9 +37,23 @@ impl<T> Command<T> {
} }
} }
/// Creates a [`Command`] that performs the action of the given future.
///
/// [`Command`]: struct.Command.html
#[cfg(target_arch = "wasm32")]
pub fn perform<A>(
future: impl Future<Output = T> + 'static,
f: impl Fn(T) -> A + 'static + Send,
) -> Command<A> {
Command {
futures: vec![Box::pin(future.map(f))],
}
}
/// Applies a transformation to the result of a [`Command`]. /// Applies a transformation to the result of a [`Command`].
/// ///
/// [`Command`]: struct.Command.html /// [`Command`]: struct.Command.html
#[cfg(not(target_arch = "wasm32"))]
pub fn map<A>( pub fn map<A>(
mut self, mut self,
f: impl Fn(T) -> A + 'static + Send + Sync, f: impl Fn(T) -> A + 'static + Send + Sync,
@ -62,6 +77,33 @@ impl<T> Command<T> {
} }
} }
/// Applies a transformation to the result of a [`Command`].
///
/// [`Command`]: struct.Command.html
#[cfg(target_arch = "wasm32")]
pub fn map<A>(
mut self,
f: impl Fn(T) -> A + 'static,
) -> Command<A>
where
T: 'static,
{
let f = std::sync::Arc::new(f);
Command {
futures: self
.futures
.drain(..)
.map(|future| {
let f = f.clone();
Box::pin(future.map(move |result| f(result)))
as BoxFuture<A>
})
.collect(),
}
}
/// Creates a [`Command`] that performs the actions of all the given /// Creates a [`Command`] that performs the actions of all the given
/// commands. /// commands.
/// ///
@ -85,6 +127,7 @@ impl<T> Command<T> {
} }
} }
#[cfg(not(target_arch = "wasm32"))]
impl<T, A> From<A> for Command<T> impl<T, A> From<A> for Command<T>
where where
A: Future<Output = T> + 'static + Send, A: Future<Output = T> + 'static + Send,
@ -96,6 +139,19 @@ where
} }
} }
#[cfg(target_arch = "wasm32")]
impl<T, A> From<A> for Command<T>
where
A: Future<Output = T> + 'static,
{
fn from(future: A) -> Self {
Self {
futures: vec![future.boxed_local()],
}
}
}
impl<T> std::fmt::Debug for Command<T> { impl<T> std::fmt::Debug for Command<T> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("Command").finish() f.debug_struct("Command").finish()