DF
У админов то все равно все удаленные сообщ видно
Size: a a a
2021 February 24
в🧇
Присоединюсь к бурчанию. Пользы нет, а вред есть от автоудаления)
S
привет
Подскажите пожалуйста как правильно совмещать Result/Option с async
Например у меня есть result:
let res: Result<Future<…>> = result.map(|i|async { … })
Как потом конвертнуть Result<Future<…>> в Result<T, E> или хотябы в Future<Result<T, E>> ?
Подскажите пожалуйста как правильно совмещать Result/Option с async
Например у меня есть result:
let res: Result<Future<…>> = result.map(|i|async { … })
Как потом конвертнуть Result<Future<…>> в Result<T, E> или хотябы в Future<Result<T, E>> ?
K
Sergey
привет
Подскажите пожалуйста как правильно совмещать Result/Option с async
Например у меня есть result:
let res: Result<Future<…>> = result.map(|i|async { … })
Как потом конвертнуть Result<Future<…>> в Result<T, E> или хотябы в Future<Result<T, E>> ?
Подскажите пожалуйста как правильно совмещать Result/Option с async
Например у меня есть result:
let res: Result<Future<…>> = result.map(|i|async { … })
Как потом конвертнуть Result<Future<…>> в Result<T, E> или хотябы в Future<Result<T, E>> ?
m
Товарищи, подскажите пожалуйста!
какая-то странная штука происходит..
передают в
все компилится, но код на месте этого spawn "виснет" т.е. я не вижу debug!() вывода сразу за ним.. не запускается сама фьюча и объект который туда передается уничтожается т.к. я в логах вижу его drop()
почему может быть такое поведение?
какая-то странная штука происходит..
передают в
tokio::spawn фьючу.. async move {...}все компилится, но код на месте этого spawn "виснет" т.е. я не вижу debug!() вывода сразу за ним.. не запускается сама фьюча и объект который туда передается уничтожается т.к. я в логах вижу его drop()
почему может быть такое поведение?
MB
Паник и дедлоков нет?
m
дедлоков вроде нету, там parking_lot мониторит свои дедлоки, я же юзаю только его RwLock
ничего не выдает насчет этого
панику попробую явно поймать уровнем выше, но вроде тоже ничего такого не замечал в логах
ничего не выдает насчет этого
панику попробую явно поймать уровнем выше, но вроде тоже ничего такого не замечал в логах
С
дедлоков вроде нету, там parking_lot мониторит свои дедлоки, я же юзаю только его RwLock
ничего не выдает насчет этого
панику попробую явно поймать уровнем выше, но вроде тоже ничего такого не замечал в логах
ничего не выдает насчет этого
панику попробую явно поймать уровнем выше, но вроде тоже ничего такого не замечал в логах
debug! в какой-то логер пишет? Есть возможность на dbg или println заменить?
m
debug! в какой-то логер пишет? Есть возможность на dbg или println заменить?
это на андройде, там у меня кастомная логгилка которая пишет в logcat
попробую на эти варианты
но вообще такой вот код
```
```
пишет только первую строку
и все.. не пишет ни последнюю, ни первую внутри async {} фьючи (
но пишет лог drop() стркутуры
platform_services::android: try to spawn decoder future..
platform_services::android::media_codec: [543729196352] remove MediaCodecPtr from list. CODECS len 0
попробую на эти варианты
но вообще такой вот код
```
tokio::spawn({
let mut decoder = decoder.clone();
debug!("try to spawn decoder future..");
async move {
debug!("decoder start() spawn..");
let res = decoder.start_async().await;
debug!("decoder ends with res {:?}", res);
}
});
debug!("spawn decoder future ok");```
пишет только первую строку
"try to spawn decoder future.."и все.. не пишет ни последнюю, ни первую внутри async {} фьючи (
"decoder start() spawn..")но пишет лог drop() стркутуры
decoderplatform_services::android: try to spawn decoder future..
platform_services::android::media_codec: [543729196352] remove MediaCodecPtr from list. CODECS len 0
m
вся эта штука запускается внутри отдельного потока
```
```
но я так много чего делал, вроде проблем не было никогда
```
std::thread::spawn(move || {
let mut rt = tokio::runtime::Runtime::new().unwrap();
if let Err(err) = rt.block_on(
async {
platform_services::test_decoder().await
}
) {
debug!("test_decoder err: {}", err)
};
debug!("stop decoder thread");
});```
но я так много чего делал, вроде проблем не было никогда
ph
может block_on раньше заканчивается, т.к. ты не ждешь ничего?
m
может block_on раньше заканчивается, т.к. ты не ждешь ничего?
в test_decoder несколько tokio::spawn и еще свой while на получение данных из выходного стрима
там все логами обвешал, они не пишутся..
соответственно block_on висит
но попробую проверить это все более внимательно
там все логами обвешал, они не пишутся..
соответственно block_on висит
но попробую проверить это все более внимательно
m
попробую еще tokio::spawn на join!() заменить..
m
tokio::task::yield_now().await;раскидывал везде, но не помогало..
m
попробую еще tokio::spawn на join!() заменить..
ну вот, кстати, после join!() вместо spawn видно что логи уже другие, что-то там запустилось явно.. буду разбираться
m
да, какая-то непонятная дичь..
c join!() все заработало на удивление классно!
пришлось заменить на синхронный
иначе оно подвисало на нем
c join!() все заработало на удивление классно!
tokio::fs::read(&path).awaitпришлось заменить на синхронный
std::fs::read(&path)иначе оно подвисало на нем
MB
А токио точно должен работать на андроиде?
m
да вроде работал всегда.. не знаю есть ли официальная поддержка
я просто юзал и проблем не было)
я просто юзал и проблем не было)
MB
tokio::fs::read внутри себя делает spawn_blocking.
То есть выглядит так, что при любом спавне приложение разваливается.
То есть выглядит так, что при любом спавне приложение разваливается.
m
файлы, правда не читал.. только сеть и таймеры