File_info_poller send_stream() problem
- Dominant language
- Rust
- Stars
- 25
- Forks
- 36
- Avg merge
- 2d 20h
- Merged PRs (30d)
- 11
Description
Hello.
When I worked with the `file_store` library I faced a critical (as for me) issue in the `file_info_poller` module.
Currently, I don't use this part of the code but I think it is worth mentioning.
I had an error "Error streaming entry" due to reset connections by a peer (I kept it too long open) .
But I can't detect it because all I have "outside" is only the next() function.
So I can't distinguish if it is the end of the file or an error in a stream. In both cases, the loop finishes because next() returns None.
```rust
let mut rewards = file.into_stream(&mut tx).await?;
while let Some(reward) = rewards.next().await {
...
}
```
https://github.com/helium/oracles/blob/main/file_store/src/file_info_poller.rs#L175

Contributor guide
Assessment
This issue has not been assessed yet.