Mirrors/sqlx
2
0
Fork 0
mirror of https://github.com/launchbadge/sqlx synced 2024-09-20 14:21:57 +00:00
Code Issues Projects Releases Packages Wiki Activity

chore: update listener example

Browse source
This commit is contained in:
Ryan Leckey 2020-07-27 02:22:59 -07:00
parent d04d612368
commit 4857d051e1
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
examples/postgres/listen/src/main.rs
View file

@ -11,9 +11,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
println!("Building PG pool.");
let conn_str =
std::env::var("DATABASE_URL").expect("Env var DATABASE_URL is required for this example.");
let pool = sqlx::PgPool::new(&conn_str).await?;
let pool = sqlx::PgPool::connect(&conn_str).await?;
let mut listener = PgListener::new(&conn_str).await?;
let mut listener = PgListener::connect(&conn_str).await?;
// let notify_pool = pool.clone();
let _t = async_std::task::spawn(async move {