Noratrieb/ice-104649
1
0
Fork 0
mirror of https://github.com/Noratrieb/ice-104649.git synced 2026-01-14 12:35:02 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

simplify

Browse source
This commit is contained in:
nora 2022-11-20 22:19:39 +01:00
parent 58cfda5ac1
commit 9db8176c8b
No known key found for this signature in database
1 changed files with 8 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/main.rs
View file

@ -11,7 +11,7 @@ impl<T> Project for Wrap<T> {
pub trait Stream {
type Item;
fn for_each<Fut, F>(self, f: F)
fn async_match_on_projected<Fut, F>(self, f: F)
where
F: FnMut(Self::Item) -> Fut,
Self: Sized,
@ -20,21 +20,21 @@ pub trait Stream {
}
}
pub struct Map<F>(F);
pub struct ProjectFnOutput<F>(F);
impl<F> Stream for Map<F>
impl<F> Stream for ProjectFnOutput<F>
where
F: FnOnce1,
F: GetFnOutput,
F::Output: Project,
{
type Item = <F::Output as Project>::Assoc;
}
pub trait FnOnce1 {
pub trait GetFnOutput {
type Output;
}
impl<T, R> FnOnce1 for T
impl<T, R> GetFnOutput for T
where
T: FnOnce() -> R,
{
@ -42,9 +42,8 @@ where
}
fn main() {
let bodies = Map(|| Wrap(Result::Ok(())));
bodies.for_each(|b| async {
let proj = ProjectFnOutput(|| Wrap(Result::Ok(())));
proj.async_match_on_projected(|b| async {
match b {
Ok(Ok(url)) => {}
Err(e) => {}