temp/ztb_recode
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

block_in_place in transcoder

Browse Source
This commit is contained in:
Dmitry Belyaev 2022-09-23 22:03:19 +03:00
parent 0ad014a544
commit 0b98540e35
Signed by: b4tman
GPG Key ID: 41A00BF15EA7E5F3
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main.rs
View File

@ -120,14 +120,12 @@ async fn transcoder_task(
encoding_to: EncodingRef, encoding_to: EncodingRef,
) { ) {
while let Some(FileData { name, data }) = rx.recv().await { while let Some(FileData { name, data }) = rx.recv().await {
let new_data = task::spawn_blocking(move || { let new_data = task::block_in_place(move || {
let text = encoding_from.decode(&data, DecoderTrap::Ignore).unwrap(); let text = encoding_from.decode(&data, DecoderTrap::Ignore).unwrap();
encoding_to encoding_to
.encode(text.as_str(), EncoderTrap::Ignore) .encode(text.as_str(), EncoderTrap::Ignore)
.unwrap() .unwrap()
}) });
.await
.unwrap();
tx.send(FileData { tx.send(FileData {
name, name,