OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2024-12-22 14:35:36 +01:00
Code Issues Projects Releases Packages Wiki Activity

Pin RequestFuture

Browse source
This commit is contained in:
Waffle 2019-09-03 20:23:52 +03:00
parent 9f8396f752
commit f100bdc7ed
3 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/core/requests/get_me.rs
View file

@ -11,7 +11,7 @@ impl Request for GetMe {
type ReturnValue = User;
fn send(self) -> RequestFuture<ResponseResult<Self::ReturnValue>> {
Box::new(async move {
Box::pin(async move {
network::request(&self.info.client, &self.info.token, "getMe", None).await
})
}

9
src/core/requests/mod.rs
View file

@ -1,4 +1,5 @@
use std::future::Future;
use std::pin::Pin;
use reqwest::r#async::Client;
use reqwest::StatusCode;
@ -42,7 +43,9 @@ pub trait Request {
fn send(self) -> RequestFuture<ResponseResult<Self::ReturnValue>>;
}
pub type RequestFuture<T> = Box<dyn Future<Output = T>>;
pub type RequestFuture<T> = Pin<Box<dyn Future<Output = T> + Send>>;
// todo: better name?
#[derive(Debug)]
@ -65,3 +68,7 @@ pub enum ChatId {
pub mod get_me;
pub mod send_message;
fn a() {
use futures;
}

2
src/core/requests/send_message.rs
View file

@ -25,7 +25,7 @@ impl Request for SendMessage {
type ReturnValue = Message;
fn send(self) -> RequestFuture<ResponseResult<Self::ReturnValue>> {
Box::new(async move {
Box::pin(async move {
let params = FormBuilder::new()
.add("chat_id", &self.chat_id)
.add("text", &self.text)