snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-26 03:55:07 +08:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Use with tokio channel in Meilisearch

Browse Source
This commit is contained in:
Louis Dureuil 2024-01-23 16:53:05 +01:00
parent 07263bc0d7
commit 20c75aa85c
No known key found for this signature in database
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
meilisearch/src/main.rs
View File

@ -57,13 +57,13 @@ fn setup(opt: &Opt) -> anyhow::Result<()> {
),
);
std::thread::spawn(move || {
tokio::task::spawn(async move {
loop {
trace.flush().unwrap();
match trace.receive() {
Ok(ControlFlow::Continue(_)) => continue,
Ok(ControlFlow::Break(_)) => break,
Err(_) => todo!(),
match tokio::time::timeout(std::time::Duration::from_secs(1), trace.receive()).await {
Ok(Ok(ControlFlow::Continue(()))) => continue,
Ok(Ok(ControlFlow::Break(_))) => break,
Ok(Err(_)) => todo!(),
Err(_) => trace.flush().unwrap(),
}
}
while trace.try_receive().is_ok() {}