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

Fix Clippy

Browse source
This commit is contained in:
Temirkhan Myrzamadi 2020-03-30 20:27:01 +06:00
parent 548ea06ad0
commit 8ea460e04f
1 changed files with 13 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
src/dispatching/update_listeners.rs
View file

@ -101,26 +101,15 @@
//! [webhook]: https://en.wikipedia.org/wiki/Webhook
use futures::{stream, Stream, StreamExt};
use tokio::sync::mpsc;
use warp::Filter;
use crate::{
bot::Bot,
prelude::ResponseResult,
requests::Request,
types::{AllowedUpdate, Update},
RequestError,
};
use either::Either;
use reqwest::Url;
use std::{
convert::{Infallible, TryInto},
net::SocketAddr,
path::Path,
sync::Arc,
time::Duration,
};
use std::{convert::TryInto, sync::Arc, time::Duration};
/// A generic update listener.
pub trait UpdateListener<E>: Stream<Item = Result<Update, E>> {
@ -212,17 +201,21 @@ pub fn polling(
#[cfg(feature = "webhooks")]
pub async fn webhook<KP, KB, CP, CB>(
url: Url,
addr: SocketAddr,
key: Either<KP, KB>,
cert: Either<CP, CB>,
) -> ResponseResult<impl UpdateListener<Infallible>>
url: reqwest::Url,
addr: std::net::SocketAddr,
key: either::Either<KP, KB>,
cert: either::Either<CP, CB>,
) -> crate::prelude::ResponseResult<impl UpdateListener<std::convert::Infallible>>
where
KP: AsRef<Path>,
KP: AsRef<std::path::Path>,
KB: AsRef<[u8]>,
CP: AsRef<Path>,
CP: AsRef<std::path::Path>,
CB: AsRef<[u8]>,
{
use either::Either;
use tokio::sync::mpsc;
use warp::Filter;
let (tx, rx) = mpsc::unbounded_channel();
let server = warp::post().and(warp::path(url)).and(warp::body::json()).map(