那些遇到过的问题

如何返回一个由一个函数生成的迭代器,该函数采用"自我"(当自己在本地创建时)？

Nas*_*nas 5 rust

更新:帖子的标题已更新,答案已移出问题.简短的回答是你不能.请看我对这个问题的回答.

我下面的错误处理的博客文章在这里(GitHub的,因为这是在这里),我试图进行一些修改代码,以便在search函数返回Iterator,而不是一个Vec.这太疯狂了,我被困住了.

我已经达到了这一点:

fn search<'a, P: AsRef<Path>>(file_path: &Option<P>, city: &str)
    -> Result<FilterMap<csv::reader::DecodedRecords<'a, Box<Read>, Row>,
                        FnMut(Result<Row, csv::Error>)
                            -> Option<Result<PopulationCount, csv::Error>>>,
              CliError>  {
    let mut found = vec![];
    let input: Box<io::Read> = match *file_path {
        None => Box::new(io::stdin()),
        Some(ref file_path) => Box::new(try!(fs::File::open(file_path))),
    };

    let mut rdr = csv::Reader::from_reader(input);
    let closure = |row: Result<Row, csv::Error>| -> Option<Result<PopulationCount, csv::Error>> {
        let row = match row {
            Ok(row) => row,
            Err(err) => return Some(Err(From::from(err))),
        };
        match row.population {
            None => None,
            Some(count) => if row.city == city {
                Some(Ok(PopulationCount {
                    city: row.city,
                    country: row.country,
                    count: count,
                }))
            } else {
                None
            }
        }
    };
    let found = rdr.decode::<Row>().filter_map(closure);

    if !found.all(|row| match row {
        Ok(_) => true,
        _ => false,
    }) {
        Err(CliError::NotFound)
    } else {
        Ok(found)
    }
}
Run Code Online (Sandbox Code Playgroud)

来自编译器的以下错误:

src/main.rs:97:1: 133:2 error: the trait `core::marker::Sized` is not implemented for the type `core::ops::FnMut(core::result::Result<Row, csv::Error>) -> core::option::Option<core::result::Result<PopulationCount, csv::Error>>` [E0277]
src/main.rs:97 fn search<'a, P: AsRef<Path>>(file_path: &Option<P>, city: &str) -> Result<FilterMap<csv::reader::DecodedRecords<'a, Box<Read>, Row>, FnMut(Result<Row, csv::Error>) -> Option<Result<PopulationCount, csv::Error>>>, CliError>  {
src/main.rs:98     let mut found = vec![];
src/main.rs:99     let input: Box<io::Read> = match *file_path {
src/main.rs:100         None => Box::new(io::stdin()),
src/main.rs:101         Some(ref file_path) => Box::new(try!(fs::File::open(file_path))),
src/main.rs:102     };
                ...
src/main.rs:97:1: 133:2 note: `core::ops::FnMut(core::result::Result<Row, csv::Error>) -> core::option::Option<core::result::Result<PopulationCount, csv::Error>>` does not have a constant size known at compile-time
src/main.rs:97 fn search<'a, P: AsRef<Path>>(file_path: &Option<P>, city: &str) -> Result<FilterMap<csv::reader::DecodedRecords<'a, Box<Read>, Row>, FnMut(Result<Row, csv::Error>) -> Option<Result<PopulationCount, csv::Error>>>, CliError>  {
src/main.rs:98     let mut found = vec![];
src/main.rs:99     let input: Box<io::Read> = match *file_path {
src/main.rs:100         None => Box::new(io::stdin()),
src/main.rs:101         Some(ref file_path) => Box::new(try!(fs::File::open(file_path))),
src/main.rs:102     };
                ...
error: aborting due to previous error
Run Code Online (Sandbox Code Playgroud)

我也试过这个函数定义:

fn search<'a, P: AsRef<Path>, F>(file_path: &Option<P>, city: &str)
    -> Result<FilterMap<csv::reader::DecodedRecords<'a, Box<Read>, Row>, F>,
              CliError>
    where F:  FnMut(Result<Row, csv::Error>)
                  -> Option<Result<PopulationCount, csv::Error>> {
Run Code Online (Sandbox Code Playgroud)

来自编译器的这些错误:

src/main.rs:131:12: 131:17 error: mismatched types:
 expected `core::iter::FilterMap<csv::reader::DecodedRecords<'_, Box<std::io::Read>, Row>, F>`,
 found    `core::iter::FilterMap<csv::reader::DecodedRecords<'_, Box<std::io::Read>, Row>, [closure src/main.rs:105:19: 122:6]>`
(expected type parameter,
found closure) [E0308]
src/main.rs:131         Ok(found)
Run Code Online (Sandbox Code Playgroud)

我不能Box关闭,因为它不会被接受filter_map.

然后我尝试了这个:

fn search<'a, P: AsRef<Path>>(file_path: &Option<P>, city: &'a str)
    -> Result<(Box<Iterator<Item=Result<PopulationCount, csv::Error>> + 'a>, csv::Reader<Box<io::Read>>), CliError> {
    let input: Box<io::Read> = match *file_path {
        None => box io::stdin(),
        Some(ref file_path) => box try!(fs::File::open(file_path)),
    };

    let mut rdr = csv::Reader::from_reader(input);
    let mut found = rdr.decode::<Row>().filter_map(move |row| {
        let row = match row {
            Ok(row) => row,
            Err(err) => return Some(Err(err)),
        };
        match row.population {
            None => None,
            Some(count) if row.city == city => {
                Some(Ok(PopulationCount {
                    city: row.city,
                    country: row.country,
                    count: count,
                }))
            },
            _ => None,
        }
    });

    if found.size_hint().0 == 0 {
        Err(CliError::NotFound)
    } else {
        Ok((box found, rdr))
    }
}

fn main() {
    let args: Args = Docopt::new(USAGE)
                            .and_then(|d| d.decode())
                            .unwrap_or_else(|err| err.exit());


    match search(&args.arg_data_path, &args.arg_city) {
        Err(CliError::NotFound) if args.flag_quiet => process::exit(1),
        Err(err) => fatal!("{}", err),
        Ok((pops, rdr)) => for pop in pops {
            match pop {
                Err(err) => panic!(err),
                Ok(pop) => println!("{}, {}: {} - {:?}", pop.city, pop.country, pop.count, rdr.byte_offset()),
            }
        }
    }
}
Run Code Online (Sandbox Code Playgroud)

这给了我这个错误:

src/main.rs:107:21: 107:24 error: `rdr` does not live long enough
src/main.rs:107     let mut found = rdr.decode::<Row>().filter_map(move |row| {
                                    ^~~
src/main.rs:100:117: 130:2 note: reference must be valid for the lifetime 'a as defined on the block at 100:116...
src/main.rs:100     -> Result<(Box<Iterator<Item=Result<PopulationCount, csv::Error>> + 'a>, csv::Reader<Box<io::Read>>), CliError> {
src/main.rs:101     let input: Box<io::Read> = match *file_path {
src/main.rs:102         None => box io::stdin(),
src/main.rs:103         Some(ref file_path) => box try!(fs::File::open(file_path)),
src/main.rs:104     };
src/main.rs:105     
                ...
src/main.rs:106:51: 130:2 note: ...but borrowed value is only valid for the block suffix following statement 1 at 106:50
src/main.rs:106     let mut rdr = csv::Reader::from_reader(input);
src/main.rs:107     let mut found = rdr.decode::<Row>().filter_map(move |row| {
src/main.rs:108         let row = match row {
src/main.rs:109             Ok(row) => row,
src/main.rs:110             Err(err) => return Some(Err(err)),
src/main.rs:111         };
                ...
error: aborting due to previous error
Run Code Online (Sandbox Code Playgroud)

我设计的是错误的,还是我采取了错误的方法？我错过了一些非常简单和愚蠢的东西吗？我不知道从哪里开始.

blu*_*uss 9

返回迭代器是可能的,但它有一些限制.

为了证明它是可能的,两个例子,(A)具有显式迭代器类型和(B)使用装箱(围栏链接).

use std::iter::FilterMap;

fn is_even(elt: i32) -> Option<i32> {
    if elt % 2 == 0 {
        Some(elt)
    } else { None }
}

/// (A)
pub fn evens<I: IntoIterator<Item=i32>>(iter: I)
    -> FilterMap<I::IntoIter, fn(I::Item) -> Option<I::Item>>
{
    iter.into_iter().filter_map(is_even)
}

/// (B)
pub fn cumulative_sums<'a, I>(iter: I) -> Box<Iterator<Item=i32> + 'a>
    where I: IntoIterator<Item=i32>,
          I::IntoIter: 'a,
{
    Box::new(iter.into_iter().scan(0, |acc, x| {
        *acc += x;
        Some(*acc)
    }))
}

fn main() {
    // The output is:
    //  0 is even, 10 is even, 
    //  1, 3, 6, 10, 
    for even in evens(vec![0, 3, 7, 10]) {
        print!("{} is even, ", even);
    }
    println!("");

    for cs in cumulative_sums(1..5) {
        print!("{}, ", cs);
    }
    println!("");
}
Run Code Online (Sandbox Code Playgroud)

您遇到了(A) - 显式类型的问题!我们从具有|a, b, c| ..语法的常规lambda表达式获得的无盒装闭包具有唯一的匿名类型.函数需要显式返回类型,因此在此处不起作用.

返回闭包的一些解决方案:

  • 使用函数指针,fn()如示例(A)所示.通常,您不需要关闭环境.
  • 封闭盒子.这是合理的,即使迭代器目前不支持调用它.不是你的错.
  • 包装迭代器
  • 返回自定义迭代器结构.需要一些样板.

你可以看到,在例子(B)中,我们必须非常小心一生.它说返回值是Box<Iterator<Item=i32> + 'a>什么,这是什么'a？这是盒子内任何东西所需的最短寿命!我们也把它'a绑定I::IntoIter- 这确保我们可以把它放在盒子里面.

如果你只是说它Box<Iterator<Item=i32>>会假设'static.

我们必须明确声明我们盒子内容的生命周期.为了安全起见.

这实际上是您的功能的根本问题.你有这个:DecodedRecords<'a, Box<Read>, Row>, F>

看到了,一个'a!这种类型借用了一些东西.问题是它没有从输入中借用它.'a输入没有.

您将意识到它借鉴了您在函数期间创建的值,并且该函数返回时该值的生命周期结束.我们无法DecodedRecords<'a>从函数返回,因为它想借用局部变量.

然后去哪儿？我最简单的答案是执行与csv相同的拆分.拥有读者的一部分(结构或值),以及作为迭代器并从读者借用的一部分(结构或值).

也许csv crate有一个拥有它正在处理的阅读器的所有权的解码器.在这种情况下,您可以使用它来消除借贷问题.

Nas*_*nas 2

这个答案基于@bluss的答案+ irc​​.mozilla.org 上 #rust 的帮助

从代码中看不明显的一个问题，以及导致上面显示的最终错误的问题，与 的定义有关csv::Reader::decode（请参阅其源代码）。需要&'a mut self，这个问题的解释包含在这个答案中。这本质上会导致读取器的生命周期受限于它所调用的块。解决此问题的方法是将函数分成两半（因为我无法控制函数定义，如前面的答案链接中所建议的）。我需要读取器在函数内有效的生命周期main，以便读取器可以向下传递到search函数中。请参阅下面的代码（肯定可以进一步清理）：

fn population_count<'a, I>(iter: I, city: &'a str)
    -> Box<Iterator<Item=Result<PopulationCount,csv::Error>> + 'a>
    where I: IntoIterator<Item=Result<Row,csv::Error>>,
          I::IntoIter: 'a,
{
    Box::new(iter.into_iter().filter_map(move |row| {
        let row = match row {
            Ok(row) => row,
            Err(err) => return Some(Err(err)),
        };

        match row.population {
            None => None,
            Some(count) if row.city == city => {
                Some(Ok(PopulationCount {
                    city: row.city,
                    country: row.country,
                    count: count,
                }))
            },
            _ => None,
        }
    }))
}

fn get_reader<P: AsRef<Path>>(file_path: &Option<P>)
    -> Result<csv::Reader<Box<io::Read>>, CliError>
{
    let input: Box<io::Read> = match *file_path {
        None => Box::new(io::stdin()),
        Some(ref file_path) => Box::new(try!(fs::File::open(file_path))),
    };

    Ok(csv::Reader::from_reader(input))
}

fn search<'a>(reader: &'a mut csv::Reader<Box<io::Read>>, city: &'a str)
    -> Box<Iterator<Item=Result<PopulationCount, csv::Error>> + 'a>
{
    population_count(reader.decode::<Row>(), city)
}

fn main() {
    let args: Args = Docopt::new(USAGE)
        .and_then(|d| d.decode())
        .unwrap_or_else(|err| err.exit());

    let reader = get_reader(&args.arg_data_path);
    let mut reader = match reader {
        Err(err) => fatal!("{}", err),
        Ok(reader) => reader,
    };

    let populations = search(&mut reader, &args.arg_city);
    let mut found = false;
    for pop in populations {
        found = true;
        match pop {
            Err(err) => fatal!("fatal !! {}", err),
            Ok(pop) => println!("{}, {}: {}", pop.city, pop.country, pop.count),
        }
    }

    if !(found || args.flag_quiet) {
        fatal!("{}", CliError::NotFound);
    }
}
Run Code Online (Sandbox Code Playgroud)

为了让它发挥作用，我学到了很多东西，并且对编译器错误有了更多的认识。现在很清楚，如果这是 C，上面的最后一个错误实际上可能会导致段错误，这会更难调试。我还意识到，从预先计算的 vec 转换为迭代器需要更多地考虑内存何时进入和超出范围；我不能只更改一些函数调用和返回类型就到此为止。

归档时间：

查看次数：

1115 次

最近记录：

10 年，3 月 前
返回迭代器(或任何其他特征)的正确方法是什么？ 92
为什么我的结构不够长寿？ 5
更多相关链接
相关归档
是否有内置函数来计算两个集合的差异？ 11
有没有办法从闭包内部的函数返回？ 7
为什么Clippy建议通过Arc作为参考？ 6
如何从 Rust 中的 stdin 读取的行中删除换行符和回车符？ 6
如何用git2-rs Rust箱子完成"git pull"？ 5
如何在 Rust 的结构体中实现动态二维数组？ 5
读取字符串，直到换行 4
如何将数据移动到多个Rust闭包中？ 4
为什么Rust无法找到wl_display_get_registry？ 3
为什么我无法从互联网访问这个 Rust 简单服务器？ 2
难疑归档
RESTful编程究竟是什么？ 3917
夏令时和时区最佳实践 2021
如何使div 100%的浏览器窗口高度？ 2016
在JavaScript中解析JSON？ 1642
使用jQuery将表单数据转换为JavaScript对象 1580
在C#中调用基础构造函数 1398
Git push需要用户名和密码 1327
varchar和nvarchar有什么区别？ 1300
angular-route和angular-ui-router之间有什么区别？ 1064
字段和属性之间有什么区别？ 1032