Garmelon/tablejohn
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use advance() instead of split_to()

Browse source
This commit is contained in:
Joscha 2023-08-14 14:01:34 +02:00
parent 2620530cc2
commit 6b8ae19ba5
3 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

1
Cargo.lock generated
View file

@ -3169,6 +3169,7 @@ dependencies = [
"askama_axum", "askama_axum",
"axum", "axum",
"axum-extra", "axum-extra",
"bytes",
"clap", "clap",
"directories", "directories",
"flate2", "flate2",

1
Cargo.toml
View file

@ -9,6 +9,7 @@ askama = { version = "0.12.0", features = ["with-axum"] }
askama_axum = "0.3.0" askama_axum = "0.3.0"
axum = { version = "0.6.19", features = ["macros", "headers"] } axum = { version = "0.6.19", features = ["macros", "headers"] }
axum-extra = { version = "0.7.7", features = ["typed-routing"] } axum-extra = { version = "0.7.7", features = ["typed-routing"] }
bytes = "1.4.0"
clap = { version = "4.3.19", features = ["derive", "deprecated"] } clap = { version = "4.3.19", features = ["derive", "deprecated"] }
directories = "5.0.1" directories = "5.0.1"
flate2 = "1.0.26" flate2 = "1.0.26"

4
src/worker/tree.rs
View file

@ -2,7 +2,7 @@
use std::{io, path::PathBuf}; use std::{io, path::PathBuf};
use axum::body::Bytes; use bytes::{Buf, Bytes};
use flate2::read::GzDecoder; use flate2::read::GzDecoder;
use futures::{Stream, StreamExt}; use futures::{Stream, StreamExt};
use reqwest::Response; use reqwest::Response;
@ -35,7 +35,7 @@ impl io::Read for ReceiverReader {
let mut slice = &*self.rest; let mut slice = &*self.rest;
let result = slice.read(buf); let result = slice.read(buf);
let _ = self.rest.split_to(self.rest.len() - slice.len()); self.rest.advance(self.rest.len() - slice.len());
result result
} }