mirror of
https://github.com/quickwit-oss/tantivy.git
synced 2025-12-23 02:29:57 +00:00
readability improvement on executor (#2615)
This commit is contained in:
@@ -41,16 +41,12 @@ impl Executor {
|
|||||||
///
|
///
|
||||||
/// Regardless of the executor (`SingleThread` or `ThreadPool`), panics in the task
|
/// Regardless of the executor (`SingleThread` or `ThreadPool`), panics in the task
|
||||||
/// will propagate to the caller.
|
/// will propagate to the caller.
|
||||||
pub fn map<
|
pub fn map<A, R, F>(&self, f: F, args: impl Iterator<Item = A>) -> crate::Result<Vec<R>>
|
||||||
|
where
|
||||||
A: Send,
|
A: Send,
|
||||||
R: Send,
|
R: Send,
|
||||||
AIterator: Iterator<Item = A>,
|
|
||||||
F: Sized + Sync + Fn(A) -> crate::Result<R>,
|
F: Sized + Sync + Fn(A) -> crate::Result<R>,
|
||||||
>(
|
{
|
||||||
&self,
|
|
||||||
f: F,
|
|
||||||
args: AIterator,
|
|
||||||
) -> crate::Result<Vec<R>> {
|
|
||||||
match self {
|
match self {
|
||||||
Executor::SingleThread => args.map(f).collect::<crate::Result<_>>(),
|
Executor::SingleThread => args.map(f).collect::<crate::Result<_>>(),
|
||||||
Executor::ThreadPool(pool) => {
|
Executor::ThreadPool(pool) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user