YGGverse/ggemini
1
0
Fork 0
mirror of https://github.com/YGGverse/ggemini.git synced 2026-03-31 17:15:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

make bytes_total_limit optional

Browse source
This commit is contained in:
yggverse 2024-12-09 14:14:01 +02:00
parent 8c298977f3
commit eb32db3d3b
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/gio/file_output_stream.rs
View file

@ -16,9 +16,9 @@ pub fn move_all_from_stream_async(
cancellable: Cancellable, cancellable: Cancellable,
priority: Priority, priority: Priority,
bytes: ( bytes: (
usize, // bytes_in_chunk usize, // bytes_in_chunk
usize, // bytes_total_limit Option<usize>, // bytes_total_limit, `None` to unlimited
usize, // bytes_total usize, // bytes_total
), ),
callback: ( callback: (
impl Fn((Bytes, usize)) + 'static, // on_chunk impl Fn((Bytes, usize)) + 'static, // on_chunk
@ -41,8 +41,10 @@ pub fn move_all_from_stream_async(
on_chunk((bytes.clone(), bytes_total)); on_chunk((bytes.clone(), bytes_total));
// Validate max size // Validate max size
if bytes_total > bytes_total_limit { if let Some(bytes_total_limit) = bytes_total_limit {
return on_complete(Err(Error::BytesTotal(bytes_total, bytes_total_limit))); if bytes_total > bytes_total_limit {
return on_complete(Err(Error::BytesTotal(bytes_total, bytes_total_limit)));
}
} }
// No bytes were read, end of stream // No bytes were read, end of stream