Hopiu/lychee
1
0
Fork 0
mirror of https://github.com/Hopiu/lychee.git synced 2026-03-17 05:00:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rename chain to handle

Browse source
This commit is contained in:
Thomas Zahner 2024-04-22 13:57:50 +02:00
parent ddcca65e72
commit f2b1c29bd4
5 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lychee-lib/src/chain/mod.rs
View file

@ -87,7 +87,7 @@ impl<T, R> Chain<T, R> {
pub(crate) async fn traverse(&self, mut input: T) -> ChainResult<T, R> {
use ChainResult::{Done, Next};
for e in self.0.lock().await.iter_mut() {
match e.chain(input).await {
match e.handle(input).await {
Next(r) => input = r,
Done(r) => {
return Done(r);
@ -131,7 +131,7 @@ pub trait Handler<T, R>: Debug {
///
/// #[async_trait]
/// impl Handler<Request, Status> for AddHeader {
/// async fn chain(&mut self, mut request: Request) -> ChainResult<Request, Status> {
/// async fn handle(&mut self, mut request: Request) -> ChainResult<Request, Status> {
/// // You can modify the request however you like here
/// request.headers_mut().append("X-Header", "value".parse().unwrap());
///
@ -140,7 +140,7 @@ pub trait Handler<T, R>: Debug {
/// }
/// }
/// ```
async fn chain(&mut self, input: T) -> ChainResult<T, R>;
async fn handle(&mut self, input: T) -> ChainResult<T, R>;
}
/// Client request chains
@ -195,7 +195,7 @@ mod test {
#[async_trait]
impl Handler<Result, Result> for Add {
async fn chain(&mut self, req: Result) -> ChainResult<Result, Result> {
async fn handle(&mut self, req: Result) -> ChainResult<Result, Result> {
let added = req.0 + self.0;
if added > 100 {
Done(Result(req.0))

2
lychee-lib/src/checker.rs
View file

@ -74,7 +74,7 @@ fn clone_unwrap(request: &Request) -> Request {
#[async_trait]
impl Handler<Request, Status> for Checker {
async fn chain(&mut self, input: Request) -> ChainResult<Request, Status> {
async fn handle(&mut self, input: Request) -> ChainResult<Request, Status> {
ChainResult::Done(self.retry_request(input).await)
}
}

2
lychee-lib/src/client.rs
View file

@ -1087,7 +1087,7 @@ mod tests {
#[async_trait]
impl Handler<Request, Status> for ExampleHandler {
async fn chain(&mut self, _: Request) -> ChainResult<Request, Status> {
async fn handle(&mut self, _: Request) -> ChainResult<Request, Status> {
ChainResult::Done(Status::Excluded)
}
}

2
lychee-lib/src/quirks/mod.rs
View file

@ -93,7 +93,7 @@ impl Quirks {
#[async_trait]
impl Handler<Request, Status> for Quirks {
async fn chain(&mut self, input: Request) -> ChainResult<Request, Status> {
async fn handle(&mut self, input: Request) -> ChainResult<Request, Status> {
ChainResult::Next(self.apply(input))
}
}

2
lychee-lib/src/types/basic_auth/credentials.rs
View file

@ -76,7 +76,7 @@ impl BasicAuthCredentials {
#[async_trait]
impl Handler<Request, Status> for Option<BasicAuthCredentials> {
async fn chain(&mut self, mut request: Request) -> ChainResult<Request, Status> {
async fn handle(&mut self, mut request: Request) -> ChainResult<Request, Status> {
if let Some(credentials) = self {
request
.headers_mut()