diff options
-rw-r--r-- | src/async_dag.rs | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/src/async_dag.rs b/src/async_dag.rs index f7546a4..d9b7688 100644 --- a/src/async_dag.rs +++ b/src/async_dag.rs @@ -187,17 +187,12 @@ where Backend: DagBackend<Id, N>, { dag: &'a AsyncDag<Id, N, Backend>, - backlog: Vec< - Pin< - Box< - (dyn futures::future::Future<Output = Result<Option<(Id, N)>>> - + std::marker::Send - + 'a), - >, - >, - >, + backlog: Vec<Pin<Backlog<'a, Id, N>>>, } +pub type Backlog<'a, Id, N> = + Box<(dyn futures::future::Future<Output = Result<Option<(Id, N)>>> + std::marker::Send + 'a)>; + impl<'a, Id, N, Backend> futures::stream::Stream for Stream<'a, Id, N, Backend> where Id: NodeId + Send, |