search

carllerche / syncbox

Concurrency utilities for Rust
131 stars 14 forks source link

Implement async::sequence<A: Async, I: IntoIterator<Item=A>>(i: I) -> Stream<A::Value, A::Error> #11

Closed carllerche closed 9 years ago

carllerche commented 9 years ago

Hopefully I got the type signature right...

The general idea would be to take a set of async values and return a stream representing the supplied values in order of completion.

/cc @hoverbear

reem commented 9 years ago

Type signature looks right to me.

Hoverbear commented 9 years ago

That signature looks right to me, too!

carllerche commented 9 years ago

This is done: https://github.com/carllerche/syncbox/blob/master/src/util/async/sequence.rs

Hoverbear commented 9 years ago

@carllerche Awesome! Thank you!