confirmed threaded listen vs transcribe stream is naisu
This commit is contained in:
@@ -126,7 +126,7 @@ impl Listener {
|
|||||||
loop {
|
loop {
|
||||||
match recv.recv() {
|
match recv.recv() {
|
||||||
Ok(msg) => cb(msg),
|
Ok(msg) => cb(msg),
|
||||||
Err(msg) => return,
|
Err(_) => return,
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -153,7 +153,10 @@ impl Listener {
|
|||||||
}
|
}
|
||||||
downsampled_data.push(data[upsampled as usize]);
|
downsampled_data.push(data[upsampled as usize]);
|
||||||
}
|
}
|
||||||
ch.send(downsampled_data).unwrap();
|
match ch.send(downsampled_data) {
|
||||||
|
Ok(_) => (),
|
||||||
|
Err(msg) => eprintln!("failed to ingest audio: {}", msg),
|
||||||
|
};
|
||||||
},
|
},
|
||||||
move |err| {
|
move |err| {
|
||||||
eprintln!("input error: {}", err)
|
eprintln!("input error: {}", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user