MB
Сразу ясно, что асинхронный sleep
https://crates.io/crates/lofi
Ок я зарелизил.
Size: a a a
2020 November 15
2020 November 17
2020 November 18
АМ
А с помощью каких инструментов тестировать производительность сервера, использующего gRPC? Хотелось бы что-то растовое, в идеале..
K
так это обычный http/2.0 сервер
АМ
Ну вот drill и goose не умеют в HTTP/2, как я понял.
АМ
@notplhk Спасибо, но это из экосистемы go. Родного растового, надо понимать, пока ничего нет?
ph
не видел
A
Давно не трогал асинк, пытаюсь собрать на stable свои старые фьючи 0.1.29 и получаю такое:
A
error[E0599]: no method named
--> src\bin\fh_full.rs:436:14
|
436 | .map_err(FHError::Connect)
| ^^^^^^^ method not found in
= note: the method
help: the following trait is implemented but not in scope; perhaps add a
|
1 | use futures_util::future::try_future::TryFutureExt;
map_err found for opaque type impl std::future::Future in the current scope--> src\bin\fh_full.rs:436:14
|
436 | .map_err(FHError::Connect)
| ^^^^^^^ method not found in
impl std::future::Future
|= note: the method
map_err exists but the following trait bounds were not satisfied:impl std::future::Future: futures::Future
which is required by &mut impl std::future::Future: futures::Future
impl std::future::Future: futures::Stream
which is required by &mut impl std::future::Future: futures::Stream
= help: items from traits can only be used if the trait is in scopehelp: the following trait is implemented but not in scope; perhaps add a
use for it:|
1 | use futures_util::future::try_future::TryFutureExt;
Ct
error[E0599]: no method named
--> src\bin\fh_full.rs:436:14
|
436 | .map_err(FHError::Connect)
| ^^^^^^^ method not found in
= note: the method
help: the following trait is implemented but not in scope; perhaps add a
|
1 | use futures_util::future::try_future::TryFutureExt;
map_err found for opaque type impl std::future::Future in the current scope--> src\bin\fh_full.rs:436:14
|
436 | .map_err(FHError::Connect)
| ^^^^^^^ method not found in
impl std::future::Future
|= note: the method
map_err exists but the following trait bounds were not satisfied:impl std::future::Future: futures::Future
which is required by &mut impl std::future::Future: futures::Future
impl std::future::Future: futures::Stream
which is required by &mut impl std::future::Future: futures::Stream
= help: items from traits can only be used if the trait is in scopehelp: the following trait is implemented but not in scope; perhaps add a
use for it:|
1 | use futures_util::future::try_future::TryFutureExt;
У тебя же в ошибке написано что делать надо
A
У тебя же в ошибке написано что делать надо
это не помогает
Ct
use futures::future::TryFutureExt не помогает?A
а, надо же futures-util подключить (не future)
2020 November 22
TS
всем привет
A
Как можно два joinhandle объединить в один и ожидать его?
MB
join?
MB
Или просто заавейтить по очереди
YM
Как можно два joinhandle объединить в один и ожидать его?
Можно поместить их в такую структуру например https://docs.rs/futures/0.3.8/futures/stream/futures_unordered/struct.FuturesUnordered.html
S
Привет, подскажите плиз
Если у меня есть сервис и внутри него есть поле dao:
struct Service{
dao: MyDao<La>
}
При этом чтобы вызвать дао self должен быть: &mut self
Как собственно в Futures/Tokio стримах (внутри future/async) вызывать self метод (self.some_work(i) ), который дальше вызовет метод дао (self.dao.insert) требующий мутабельности?
Такой вариант не работает 🙁
async fn some_work(&mut self, …)->hz {
…
.then(|i| move async {
self.call_self_method(i).await
}).collect().await.unwrap();
…
}
другой async self метод :
async fn call_self_method(&mut self, I: SomeType)->hz {
…
self.dao.insert(i).await
}
Как собственно правильно это делать в Futures/Tokio стримах?
Если у меня есть сервис и внутри него есть поле dao:
struct Service{
dao: MyDao<La>
}
При этом чтобы вызвать дао self должен быть: &mut self
Как собственно в Futures/Tokio стримах (внутри future/async) вызывать self метод (self.some_work(i) ), который дальше вызовет метод дао (self.dao.insert) требующий мутабельности?
Такой вариант не работает 🙁
async fn some_work(&mut self, …)->hz {
…
.then(|i| move async {
self.call_self_method(i).await
}).collect().await.unwrap();
…
}
другой async self метод :
async fn call_self_method(&mut self, I: SomeType)->hz {
…
self.dao.insert(i).await
}
Как собственно правильно это делать в Futures/Tokio стримах?