You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Similar to async-rs/async-std#129, this tracks all missing methods and functions for ParallelStream. Each method and function should take an async closure as an argument (even if it's still slightly cumbersome to do so), and expose its return future.
If you'd like to implement a method or a function, just comment on this issue and it's yours!
Missing free functions
from_fn
repeat_with
successors
Missing traits
ParallelExtend
ParallelProduct
ParallelSum
Missing stream methods
ParallelStream::all
ParallelStream::any
ParallelStream::by_ref
ParallelStream::chain
ParallelStream::cloned
ParallelStream::cmp
ParallelStream::collect
ParallelStream::copied
ParallelStream::count
ParallelStream::cycle
ParallelStream::enumerate
ParallelStream::eq
ParallelStream::filter
ParallelStream::filter_map
ParallelStream::find
ParallelStream::find_map
ParallelStream::flat_map
ParallelStream::flatten
ParallelStream::fold
ParallelStream::for_each
ParallelStream::fuse
ParallelStream::ge
ParallelStream::gt
ParallelStream::inspect
ParallelStream::last
ParallelStream::le
ParallelStream::lt
ParallelStream::map
ParallelStream::max
ParallelStream::max_by
ParallelStream::max_by_key
ParallelStream::min
ParallelStream::min_by
ParallelStream::min_by_key
ParallelStream::ne
ParallelStream::next
ParallelStream::nth
ParallelStream::partial_cmp
ParallelStream::partition
ParallelStream::peekable
ParallelStream::position
ParallelStream::product
ParallelStream::rev
ParallelStream::rposition
ParallelStream::scan
ParallelStream::size_hint
ParallelStream::skip
ParallelStream::skip_while
ParallelStream::step_by
ParallelStream::sum
ParallelStream::take
ParallelStream::take_while
ParallelStream::try_fold
ParallelStream::try_for_each
ParallelStream::unzip
ParallelStream::zip
Missing FromStream impls
FromParallelStream<()> for ()
FromParallelStream<char> for String
FromParallelStream<String> for String
FromParallelStream<&'a char> for String
FromParallelStream<&'a str> for String
FromParallelStream<T> for Cow<'a, [T]> where T: Clone
FromParallelStream<A> for Box<[A]>
FromParallelStream<A> for VecDeque<A>
FromParallelStream<Result<A, E>> for Result<V, E> where V: FromStream<A>
FromParallelStream<Option<A>> for Option<V> where V: FromStream<A>
FromParallelStream<(K, V)> for BTreeMap<K, V> where K: Ord
FromParallelStream<(K, V)> for HashMap<K, V, S> where K: Eq + Hash, S: BuildHasher + Default
FromParallelStream<T> for BinaryHeap<T> where T: Ord
FromParallelStream<T> for BTreeSet<T> where T: Ord
FromParallelStream<T> for LinkedList<T>
FromParallelStream<T> for Vec<T>
FromParallelStream<T> for HashSet<T, S> where T: Eq + Hash, S: BuildHasher + Default
Similar to async-rs/async-std#129, this tracks all missing methods and functions for
ParallelStream. Each method and function should take an async closure as an argument (even if it's still slightly cumbersome to do so), and expose its return future.If you'd like to implement a method or a function, just comment on this issue and it's yours!
Missing free functions
from_fnrepeat_withsuccessorsMissing traits
ParallelExtendParallelProductParallelSumMissing stream methods
ParallelStream::allParallelStream::anyParallelStream::by_refParallelStream::chainParallelStream::clonedParallelStream::cmpParallelStream::collectParallelStream::copiedParallelStream::countParallelStream::cycleParallelStream::enumerateParallelStream::eqParallelStream::filterParallelStream::filter_mapParallelStream::findParallelStream::find_mapParallelStream::flat_mapParallelStream::flattenParallelStream::foldParallelStream::for_eachParallelStream::fuseParallelStream::geParallelStream::gtParallelStream::inspectParallelStream::lastParallelStream::leParallelStream::ltParallelStream::mapParallelStream::maxParallelStream::max_byParallelStream::max_by_keyParallelStream::minParallelStream::min_byParallelStream::min_by_keyParallelStream::neParallelStream::nextParallelStream::nthParallelStream::partial_cmpParallelStream::partitionParallelStream::peekableParallelStream::positionParallelStream::productParallelStream::revParallelStream::rpositionParallelStream::scanParallelStream::size_hintParallelStream::skipParallelStream::skip_whileParallelStream::step_byParallelStream::sumParallelStream::takeParallelStream::take_whileParallelStream::try_foldParallelStream::try_for_eachParallelStream::unzipParallelStream::zipMissing
FromStreamimplsFromParallelStream<()> for ()FromParallelStream<char> for StringFromParallelStream<String> for StringFromParallelStream<&'a char> for StringFromParallelStream<&'a str> for StringFromParallelStream<T> for Cow<'a, [T]> where T: CloneFromParallelStream<A> for Box<[A]>FromParallelStream<A> for VecDeque<A>FromParallelStream<Result<A, E>> for Result<V, E> where V: FromStream<A>FromParallelStream<Option<A>> for Option<V> where V: FromStream<A>FromParallelStream<(K, V)> for BTreeMap<K, V> where K: OrdFromParallelStream<(K, V)> for HashMap<K, V, S> where K: Eq + Hash, S: BuildHasher + DefaultFromParallelStream<T> for BinaryHeap<T> where T: OrdFromParallelStream<T> for BTreeSet<T> where T: OrdFromParallelStream<T> for LinkedList<T>FromParallelStream<T> for Vec<T>FromParallelStream<T> for HashSet<T, S> where T: Eq + Hash, S: BuildHasher + Default