KR
FuturesUnordered? 🙃И тебя с наступающим)
Минимальных тебе латенси, равномерной загрузки по ядрам, и чтобы жизнь не принуждала запускать tokio-console в Новом Году!
Size: a a a
KR
FuturesUnordered? 🙃D
d
0
И
C
sys.block_on(async move {
let indexer = Indexer::new(indexer_config);
let stream = indexer.streamer();
actix::spawn(listen_blocks(stream));
});
sys.run()?;<impl Future as Future>::Output == ()(), found enum std::result::Result()actix::spawn(listen_blocks(stream)), как это зарезолвить? может есть какой то другой spawn )) где возвращаемое значение не захардкожено или есть какой то паттерн для решение данное проблемы.D
actix::spawn(async { if let Err(e) = listen_blocks(stream).await { tracing::error!("Listen blocks terminated with error: {:#}", e) } } )D
actix::spawn(async { let _ = listen_blocks(stream); })D
move после async)C
D
C
D
C
S
А
AZ
А
AZ
А