OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-03-23 23:29:37 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fix issues caused by the rebase

Browse source
This commit is contained in:
Maybe Waffle 2022-04-05 16:42:52 +04:00
parent 0bddb1d927
commit f83ff59709
2 changed files with 4 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
Cargo.toml
View file

@ -67,6 +67,7 @@ dptree = { version = "0.1.0" }
tokio = { version = "1.8", features = ["fs"] }
tokio-util = "0.6"
tokio-stream = "0.1.8"
url = "2.2.2"
log = "0.4"

9
src/dispatching/update_listeners/webhooks/axum.rs
View file

@ -154,10 +154,7 @@ pub fn axum_no_setup(
dispatching::{stop_token::AsyncStopToken, update_listeners},
types::Update,
};
use axum::{
extract::Extension, http::StatusCode, response::IntoResponse, routing::post,
AddExtensionLayer,
};
use axum::{extract::Extension, http::StatusCode, response::IntoResponse, routing::post};
use tokio::sync::mpsc;
use tokio_stream::wrappers::UnboundedReceiverStream;
use tower::ServiceBuilder;
@ -207,8 +204,8 @@ pub fn axum_no_setup(
let app = axum::Router::new().route(options.url.path(), post(telegram_request)).layer(
ServiceBuilder::new()
.layer(TraceLayer::new_for_http())
.layer(AddExtensionLayer::new(ClosableSender::new(tx)))
.layer(AddExtensionLayer::new(stop_flag.clone()))
.layer(Extension(ClosableSender::new(tx)))
.layer(Extension(stop_flag.clone()))
.into_inner(),
);