Это зависит уже от того как вынимать. Если через uninit, то получается вполне себе да

Да вроде проблемы есть даже если через mem::take вынимать. Если у нас enum с референсом на себя в одном варианте, который не совпадает с Default, то этот референс будет указывать на неинициализированную память после мува.

Вот эта проблема уже никак нормально не решается.

Ну так в цикле с забиранием владения подход работать не будет, придётся Option<...> иметь вне цикла, что мало чем от Fuse<...> отличается. Даже если решить проблемы с selfref

Есть аналог семафора для smol? Или семафор из токио нормально сработает?

В async-std вроде есть свой. Но должен любой работать по идее

друзья, как в tokio правильно таймаут образовать для TcpStream::connect,
обернуть в tokio::time::delay_for ??

т.е. tokio::time::timeout`
разобрался, спасибо)

нету :( Есть только мьютекс и барьер

Товарищи чет я туплю, если в ниже приведенном коде раскомментировать box trait, оно перестоет компилится

use std::{
    sync::Arc,
    convert::Infallible,
};

use tokio::sync::Mutex;
use warp::Filter;

type Ctl = Arc<Mutex<Control>>;

struct Control {
    foo: bool,
    // bar: Option<Box<dyn Bar>>,
}

trait Bar {}


#[tokio::main]
async fn main() {

    let ctl =  Arc::new(Mutex::new(Control {
        foo: true,
        // bar: None,
    }));

    let ctl = warp::any().map(move || ctl.clone());

    let routes = warp::any()
        .and(ctl)
        .and_then(dump_ctl);

    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;

}

async fn dump_ctl(ctl: Ctl) -> Result<impl warp::Reply, Infallible> {
    Ok(format!("ctl.foo = {}", ctl.lock().await.foo))
}

use std::{
    sync::Arc,
    convert::Infallible,
};

use tokio::sync::Mutex;
use warp::Filter;

type Ctl = Arc<Mutex<Control>>;

struct Control {
    foo: bool,
    // bar: Option<Box<dyn Bar>>,
}

trait Bar {}


#[tokio::main]
async fn main() {

    let ctl =  Arc::new(Mutex::new(Control {
        foo: true,
        // bar: None,
    }));

    let ctl = warp::any().map(move || ctl.clone());

    let routes = warp::any()
        .and(ctl)
        .and_then(dump_ctl);

    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;

}

async fn dump_ctl(ctl: Ctl) -> Result<impl warp::Reply, Infallible> {
    Ok(format!("ctl.foo = {}", ctl.lock().await.foo))
}

с какой ошибкой?

Но гадая по коду могу предположить что ты забыл + Send + Sync

не понимаю что от меня хочет https://docs.rs/warp/0.2.4/warp/trait.Filter.html#method.and_then

Я пробовал завернуть в Arc<Mutex> тоже самое

О, если бы она была читабельна, я бы вопросов не задавал

Попробуй код вытащи из main в отдельную асинхронную функцию. Возможно тебе #[tokio::main] ошибку портит.

Нет

В структуре просто так нельзя юзать dyn Trait - нужно как то его удавлетворить

если слишком большая — кидай на gist