We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see ourdocumentation.
There was an error while loading.Please reload this page.
1 parentb7736ae commit6c3c4ffCopy full SHA for 6c3c4ff
tests/test.rs
@@ -1,11 +1,10 @@
1
-#![feature(std_misc)]
2
externcrate postgres;
3
externcrate r2d2;
4
externcrate r2d2_postgres;
5
6
use std::sync::Arc;
7
use std::sync::mpsc;
8
-use std::thread::Thread;
+use std::thread;
9
10
use postgres::SslMode;
11
use r2d2_postgres::PostgresConnectionManager;
@@ -21,23 +20,23 @@ fn test_basic() {
21
20
let(s2, r2) = mpsc::channel();
22
23
let pool1 = pool.clone();
24
-let t1 =Thread::scoped(move ||{
+let t1 =thread::scoped(move ||{
25
let conn = pool1.get().unwrap();
26
s1.send(()).unwrap();
27
r2.recv().unwrap();
28
drop(conn);
29
});
30
31
let pool2 = pool.clone();
32
-let t2 =Thread::scoped(move ||{
+let t2 =thread::scoped(move ||{
33
let conn = pool2.get().unwrap();
34
s2.send(()).unwrap();
35
r1.recv().unwrap();
36
37
38
39
- t1.join().ok().unwrap();
40
- t2.join().ok().unwrap();
+ t1.join();
+ t2.join();
41
42
pool.get().unwrap();
43
}