m
но вообще надо изучать! Спасибо)
Size: a a a
m
MB
m
m
m
m
DN
К
.boxed() из futures::FutureExt не подходит?IG
return внутри async {…} блока, как внутри замыкания?в🧇
return внутри async {…} блока, как внутри замыкания?IG
let handle = tokio::spawn(async {
loop {
match pool.get_handle().await {
Ok(h) => return h,
Err(e) => {
error!(log, "Failed to get handle: {}", e);
tokio::time::sleep(Duration::from_secs(5)).await;
}
}
}
});
do_some_other_stuff();
let handle = handle.await;IG
for_each_concurrent на стриме ресивера flume, если что. 🙂IG
IG
IG
IG
async fn? А то хочется всё же кормить таковой !'static референсы, вместо того чтобы ваять «clone() на clone() и clone()ом погоняет». ))IG
impl Future<Output = T> + 'aasync перенести в тело, но в то же время очень хочется сахарку.)D
impl Future<Output = T> + 'aasync перенести в тело, но в то же время очень хочется сахарку.)DF
DF