Update dependencies.

This commit is contained in:
Syfaro 2020-12-06 18:49:29 -06:00
parent 124089b76f
commit f6319e6d90
3 changed files with 528 additions and 461 deletions

979
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@ -13,7 +13,7 @@ opentelemetry = "0.6"
opentelemetry-jaeger = "0.5" opentelemetry-jaeger = "0.5"
tracing-opentelemetry = "0.5" tracing-opentelemetry = "0.5"
tokio = { version = "0.2", features = ["full"] } tokio = { version = "0.3", features = ["macros", "rt-multi-thread", "sync"] }
futures = "0.3" futures = "0.3"
futures-util = "0.3" futures-util = "0.3"
@ -23,9 +23,9 @@ bytes = "0.5"
serde = { version = "1", features = ["derive"] } serde = { version = "1", features = ["derive"] }
warp = "0.2" warp = "0.2"
tokio-postgres = "0.5" tokio-postgres = "0.6"
bb8 = "0.4" bb8 = "0.6"
bb8-postgres = "0.4" bb8-postgres = "0.6"
img_hash = "3" img_hash = "3"
image = "0.23" image = "0.23"

View File

@ -67,7 +67,7 @@ pub fn image_query_sync(
distance: i64, distance: i64,
hash: Option<Vec<u8>>, hash: Option<Vec<u8>>,
) -> tokio::sync::mpsc::Receiver<Result<Vec<File>, tokio_postgres::Error>> { ) -> tokio::sync::mpsc::Receiver<Result<Vec<File>, tokio_postgres::Error>> {
let (mut tx, rx) = tokio::sync::mpsc::channel(50); let (tx, rx) = tokio::sync::mpsc::channel(50);
tokio::spawn(async move { tokio::spawn(async move {
let db = pool.get().await.unwrap(); let db = pool.get().await.unwrap();